Skip to content

Commit b35e3c5

Browse files
zhangjidi2016zhangjidi2016
andauthored
[ISSUE #376]Fix the selectorExpression not resolve placeholders. (#383)
Co-authored-by: zhangjidi2016 <zhangjidi@cmss.chinamobile.com>
1 parent 99d8837 commit b35e3c5

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/autoconfigure/ExtConsumerResetConfiguration.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ private DefaultLitePullConsumer createConsumer(ExtRocketMQConsumerConfiguration
122122
String accessChannel = resolvePlaceholders(annotation.accessChannel(), rocketMQProperties.getAccessChannel());
123123
MessageModel messageModel = annotation.messageModel();
124124
SelectorType selectorType = annotation.selectorType();
125-
String selectorExpression = annotation.selectorExpression();
125+
String selectorExpression = resolvePlaceholders(annotation.selectorExpression(), consumerConfig.getSelectorExpression());
126126
String ak = resolvePlaceholders(annotation.accessKey(), consumerConfig.getAccessKey());
127127
String sk = resolvePlaceholders(annotation.secretKey(), consumerConfig.getSecretKey());
128128
int pullBatchSize = annotation.pullBatchSize();

0 commit comments

Comments
 (0)