You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/03/08 09:47:16 UTC

[GitHub] [rocketmq-spring] deanisty opened a new issue #351: Is it needed to separate producer and consumer in RocketMQAutoConfiguration

deanisty opened a new issue #351:
URL: https://github.com/apache/rocketmq-spring/issues/351


   **FEATURE REQUEST**
   
   ![image](https://user-images.githubusercontent.com/8457847/110303755-bac49700-8035-11eb-8bcd-adef76e0a952.png)
   
   RocketMQAutoConfiguration automatically imports ListenerContainerConfiguration and will start all consumers' listening threads after springboot starts.
   But in a normal project, I actually need to separate the producer and the consumer. They may be placed in two projects separately. At present, I have not found that the official code has the function of turning on/off the listener uniformly.
   
   RocketMQAutoConfiguration 自动 import 了 ListenerContainerConfiguration 在 springboot 启动后会开启所有消费者的监听线程,
   但是在正常项目中, 其实我是需要把 producer 和 consumer 分开的,可能是分别放在两个项目里面, 目前没有发现官方的代码里有统一开启/关闭 listener 的功能
   
   


----------------------------------------------------------------
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:
users@infra.apache.org

[GitHub] [rocketmq-spring] RongtongJin commented on issue #351: Is it needed to separate producer and consumer in RocketMQAutoConfiguration

Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #351:
URL: https://github.com/apache/rocketmq-spring/issues/351#issuecomment-792698563


   > 如果代码中没有实现RocketMQMessageListener annotation的类，是不会创建RocketMQListenerContainer的。
   
   


----------------------------------------------------------------
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:
users@infra.apache.org

[GitHub] [rocketmq-spring] RongtongJin commented on issue #351: Is it needed to separate producer and consumer in RocketMQAutoConfiguration

Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #351:
URL: https://github.com/apache/rocketmq-spring/issues/351#issuecomment-792698332


   如果代码中没有实现RocketMQMessageListener 的annotation，是不会创建RocketMQListenerContainer的。


----------------------------------------------------------------
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:
users@infra.apache.org

[GitHub] [rocketmq-spring] deanisty commented on issue #351: Is it needed to separate producer and consumer in RocketMQAutoConfiguration

Posted by GitBox <gi...@apache.org>.
deanisty commented on issue #351:
URL: https://github.com/apache/rocketmq-spring/issues/351#issuecomment-793256289


   > 如果代码中没有实现RocketMQMessageListener 的annotation，是不会创建RocketMQListenerContainer的。
   
   我现在是同一个项目同一套代码部署在两个集群,一个集群服务客户端http请求,一个集群专门处理后台脚本包括消息队列的消费者, 第一个集群我是不希望消费者启动过的,但是我找不到方法在第一个集群关掉consumer的 listener


----------------------------------------------------------------
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:
users@infra.apache.org

[GitHub] [rocketmq-spring] deanisty commented on issue #351: Is it needed to separate producer and consumer in RocketMQAutoConfiguration

Posted by GitBox <gi...@apache.org>.
deanisty commented on issue #351:
URL: https://github.com/apache/rocketmq-spring/issues/351#issuecomment-792631522


   I think it is possible to create another autoconfiguration just for consumer like `RocketMQListenerAutoConfiguration`, this configuration only register and start consumer listener threads, is this more normal for decouple producers and consumers


----------------------------------------------------------------
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:
users@infra.apache.org