fix(selector): Add getter to use listener externally (#68)

* fix(selector): Add getter to use listener externally * fix(selector): Add requestReply with specific queue * fix(selector): Add requestReply with specific queue
bancolombia · Aug 1, 2024 · e70f313 · e70f313
1 parent b2e14c9
commit e70f313
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/...main/java/co/com/bancolombia/commons/jms/mq/listeners/AbstractMQRequestReplyListener.java b/...main/java/co/com/bancolombia/commons/jms/mq/listeners/AbstractMQRequestReplyListener.java
@@ -7,11 +7,13 @@
 import jakarta.jms.Destination;
 import jakarta.jms.Message;
 import jakarta.jms.Queue;
+import lombok.Getter;
 import lombok.extern.log4j.Log4j2;
 import reactor.core.publisher.Mono;
 
 import java.time.Duration;
 
+@Getter
 @Log4j2
 public abstract class AbstractMQRequestReplyListener<T> extends MQMessageListenerRetries {
     public static final int SECONDS_TIMEOUT = 30;
@@ -51,6 +53,10 @@ public Mono<T> requestReply(MQMessageCreator messageCreator, Duration timeout) {
         return sender.send(requestQueue, messageCreator).flatMap(id -> router.wait(id, timeout));
     }
 
+    public Mono<T> requestReply(String message, Destination request, Duration timeout) {
+        return sender.send(request, defaultCreator(message)).flatMap(id -> router.wait(id, timeout));
+    }
+
     private MQMessageCreator defaultCreator(String message) {
         return ctx -> {
             Message jmsMessage = ctx.createTextMessage(message);

diff --git a/...-mq/src/main/java/co/com/bancolombia/commons/jms/mq/listeners/MQRequestReplySelector.java b/...-mq/src/main/java/co/com/bancolombia/commons/jms/mq/listeners/MQRequestReplySelector.java
@@ -63,6 +63,11 @@ public Mono<Message> requestReply(MQMessageCreator messageCreator, Duration time
                         container.get(replyQueue)));
     }
 
+    public Mono<Message> requestReply(String message, Destination request, Destination reply, Duration timeout) {
+        return sender.send(request, defaultCreator(message))
+                .flatMap(id -> listener.getMessageBySelector(selector.buildSelector(id), timeout.toMillis(), reply));
+    }
+
     private MQMessageCreator defaultCreator(String message) {
         return ctx -> {
             Message jmsMessage = ctx.createTextMessage(message);