LuanLouis opened a new issue #86: Cound not configure Consumer Listener 
registration
URL: https://github.com/apache/rocketmq-spring/issues/86
 
 
   **FEATURE REQUEST**
   When the Spring serivice is annotated with `@RocketMQMessageListener`,  the 
`MessageListenerContainer` is registered automaticallly, but in some cases, we 
want to control pricisely it's registration when we deploy instances in cluster 
for processing performance.
   
   Is there any chance that let us to control `@RocketMQMessageListener` 
registration when the container boostraped?
   The configuration format would be like this:
   ```props
   rocketmq.consumer.listeners.<group-name>.<topic-name>.enabled = false
   ```
   For example, We have the a service defined as follows:
   ```java
   @Service
   @RocketMQMessageListener(topic = "ORDER_TOPIC", consumeMode = 
ConsumeMode.ORDERLY,consumerGroup = "consume-order-group")
   @Slf4j
   public class FooListener  implements RocketMQListener<String> {
       @Override
       public void onMessage(String gatewayOrderDataStr) {
           
       }
   }
   ```
   and then our configuration like this:
   ```props
   rocketmq.consumer.listeners.consume-order-group.ORDER_TOPIC.enabled = false
   ```
   then this `FooListener` is disabled and would not registered as consumer on 
RocketMQ server.
   
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to