Add new listener type

bancolombia · Feb 26, 2024 · e401e94 · e401e94
1 parent 4842d9b
commit e401e94
Show file tree

Hide file tree

Showing 5 changed files with 22 additions and 3 deletions.
diff --git a/...-utils/src/main/java/co/com/bancolombia/commons/jms/internal/models/MQListenerConfig.java b/...-utils/src/main/java/co/com/bancolombia/commons/jms/internal/models/MQListenerConfig.java
@@ -31,7 +31,14 @@ public enum SelectorMode {
     }
 
     public enum QueueType {
+        /**
+         * Used to get messages by selector
+         */
         FIXED,
+        /**
+         * This assumes that you have a location transparency router or have a single instance of this consumer
+         */
+        FIXED_SINGLE_INSTANCE,
         TEMPORARY
     }
 }
diff --git a/examples/mq-reactive/src/main/java/co/com/bancolombia/sample/app/config/UseCasesConfig.java b/examples/mq-reactive/src/main/java/co/com/bancolombia/sample/app/config/UseCasesConfig.java
@@ -5,7 +5,7 @@
 import org.springframework.context.annotation.FilterType;
 
 @Configuration
-@ComponentScan(basePackages = "co.com.bancolombia.jms.sample.domain.usecase",
+@ComponentScan(basePackages = "co.com.bancolombia.sample.domain.usecase",
         includeFilters = {
                 @ComponentScan.Filter(type = FilterType.REGEX, pattern = "^.+UseCase$")
         },

diff --git a/...rc/main/java/co/com/bancolombia/sample/drivenadapters/reqreply/MyRequestReplyAdapter.java b/...rc/main/java/co/com/bancolombia/sample/drivenadapters/reqreply/MyRequestReplyAdapter.java
@@ -19,6 +19,7 @@
 @AllArgsConstructor
 public class MyRequestReplyAdapter implements RequestGateway {
     private final MyRequestReply requestReply; // domainB
+    private final MyRequestReplySingleInstance requestReplyFixedSingle; // domainB fixed single instance (no selector)
     private final MyRequestReplyTmp requestReplyTmp; // default domain
     private final ObjectMapper mapper;
 

diff --git a/.../java/co/com/bancolombia/sample/drivenadapters/reqreply/MyRequestReplySingleInstance.java b/.../java/co/com/bancolombia/sample/drivenadapters/reqreply/MyRequestReplySingleInstance.java
@@ -0,0 +1,11 @@
+package co.com.bancolombia.sample.drivenadapters.reqreply;
+
+import co.com.bancolombia.commons.jms.api.MQRequestReply;
+import co.com.bancolombia.commons.jms.mq.ReqReply;
+
+import static co.com.bancolombia.commons.jms.internal.models.MQListenerConfig.QueueType.FIXED;
+import static co.com.bancolombia.commons.jms.internal.models.MQListenerConfig.QueueType.FIXED_SINGLE_INSTANCE;
+
+@ReqReply(requestQueue = "DEV.QUEUE.1", replyQueue = "DEV.QUEUE.2", queueType = FIXED_SINGLE_INSTANCE, connectionFactory = "domainB")
+public interface MyRequestReplySingleInstance extends MQRequestReply {
+}
diff --git a/gradle.properties b/gradle.properties
@@ -1,5 +1,5 @@
-version=2.0.1
-springBootVersion=3.2.1
+version=2.0.2
+springBootVersion=3.2.3
 gradleVersionsVersion=0.47.0
 owaspDependencyCheckVersion=9.0.9
 mqJMSVersion=3.2.1