[GitHub] [rocketmq] leoxchang opened a new issue #1619: use two DefaultMQPushConsumer listen two topics, only one topic can get message trace

[GitBox <gi...@apache.org>]

leoxchang opened a new issue #1619: use two DefaultMQPushConsumer listen two topics, only one topic can get message trace
URL: https://github.com/apache/rocketmq/issues/1619
 
 
   I used two DefaultMQPushConsumer listen two topics, that from one "nameSrv";only one topic can get message trace. I debug the rocketmq client source,I see that "AsyncTraceDispatcher.start" method throws MQClientException,because the traceProducer has bean created,the "MQ-AsyncTraceDispatcher-Thread-" thread can not start. so one DefaultMQPushConsumer can not send trace message.
   
   当使用两个”DefaultMQPushConsumer“ 监听同一个服务地址的topic时，只有其中的一个topic是可以查询到消息轨迹的，我debug源码发现"AsyncTraceDispatcher.start"这个方法抛出了MQClientException，原因是traceProducer 已经被创建过了，所以"MQ-AsyncTraceDispatcher-Thread" 线程没有被启动，导致其中的一个DefaultMQPushConsumer没法发送trace消息。

----------------------------------------------------------------
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


With regards,
Apache Git Services