Skip to content

Commit

Permalink
Selector mode from properties (#41)
Browse files Browse the repository at this point in the history
* fix(selector-mode): Get selector mode from propeties

* version
  • Loading branch information
juancgalvis authored Mar 12, 2024
1 parent 31bc1d1 commit 344ff63
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@
import co.com.bancolombia.commons.jms.mq.config.MQProperties;
import co.com.bancolombia.commons.jms.mq.config.MQSpringResolver;
import co.com.bancolombia.commons.jms.mq.config.exceptions.MQInvalidListenerException;
import co.com.bancolombia.commons.jms.mq.listeners.MQExecutorService;
import co.com.bancolombia.commons.jms.mq.listeners.MQRequestReplyListener;
import co.com.bancolombia.commons.jms.mq.listeners.MQRequestReplySelector;
import co.com.bancolombia.commons.jms.utils.MQMessageListenerUtils;
Expand Down Expand Up @@ -62,7 +61,8 @@ public static Object createMQReqReply(ReqReply annotation, MQSpringResolver reso
RetryableConfig retryableConfig = resolver.getRetryableConfig();
Destination destination = resolveDestination(annotation, resolver, properties);
if (listenerConfig.getQueueType() == MQListenerConfig.QueueType.FIXED) {
SelectorModeProvider selectorModeProvider = getSelectorModeProvider(resolver, annotation.selectorMode(),
String selectorMode = resolver.resolveString(annotation.selectorMode());
SelectorModeProvider selectorModeProvider = getSelectorModeProvider(resolver, selectorMode,
listenerConfig.getConcurrency());
MQMultiContextMessageSelectorListenerSync selectorListener = new MQMultiContextMessageSelectorListenerSync(
listenerConfig,
Expand Down
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
version=2.1.0
version=2.1.1
springBootVersion=3.2.3
gradleVersionsVersion=0.47.0
owaspDependencyCheckVersion=9.0.9
Expand Down

0 comments on commit 344ff63

Please sign in to comment.