-
Notifications
You must be signed in to change notification settings - Fork 894
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
How RocketMQMessageListener Sets Tag? #103
Comments
Refer this attribute can be used for |
@fangjian0423 now the tag not support resolvePlaceholders (eg:selectorExpression=${my.xx.tag} ),the default is * 。 when used,we should implement RocketMQPushConsumerLifecycleListener to set other info。 |
contributors are welcome to support resolvePlaceholders. |
@fangjian0423 i review the source code ;ListenerContainerConfiguration#createRocketMQListenerContainer set instance of RocketMQMessageListener to instance of DefaultRocketMQListenerContainer,then execute the method DefaultRocketMQListenerContainer#initRocketMQPushConsumer 。I cannot find resolvePlaceholders where be used for the property of selectorExpression |
It is not supported and welcome to contribute it. |
@RocketMQMessageListener(topic = "${demo.rocketmq.test.consumer.topic}",selectorExpression="${demo.rocketmq.test.consumer.tags}" ,consumerGroup = "${demo.rocketmq.test.consumer.group}")
@fangjian0423 我的这个pull request 有机会被merge吗? |
…estyle and update test class with actual meaning.
…estyle and update test class with actual meaning.
[ISSUE #103]Support resolvePlaceholders for selectorExpression
@RocketMQMessageListener(topic = "${demo.rocketmq.test.consumer.topic}",selectorExpression="${demo.rocketmq.test.consumer.tags}" ,consumerGroup = "${demo.rocketmq.test.consumer.group}")
…estyle and update test class with actual meaning.
…estyle and update test class with actual meaning.
No description provided.
The text was updated successfully, but these errors were encountered: