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 2020/06/03 01:52:47 UTC

[GitHub] [rocketmq-client-go] navychi opened a new issue #497: rocketmq-client-go consumer restart with shutdown and start

navychi opened a new issue #497:
URL: https://github.com/apache/rocketmq-client-go/issues/497


   rmqClient will put into clientMap(sync.Map) when create a new GetOrNewRocketMQClient.
   ![image](https://user-images.githubusercontent.com/43361137/83586375-d5398380-a57e-11ea-91e5-9663834c49d2.png)
   
   But rmqClient did not remove when shutdown consumer.
   ![image](https://user-images.githubusercontent.com/43361137/83586443-087c1280-a57f-11ea-86ed-044ff730d456.png)
   
   So if I want to shutdown the consumer. And then re-start consumer again(Required by business logic), The new consumer will use old connection which is closed. 
   So if I want to realization consumer restart logic. Will it be supported in the future. or The Architecture design is like this which not ready to support consumer restart logic.
   


----------------------------------------------------------------
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-client-go] maixiaohai closed issue #497: rocketmq-client-go consumer restart with shutdown and start

Posted by GitBox <gi...@apache.org>.

maixiaohai closed issue #497:
URL: https://github.com/apache/rocketmq-client-go/issues/497


   


-- 
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-client-go] YiyangLin commented on issue #497: rocketmq-client-go consumer restart with shutdown and start

Posted by GitBox <gi...@apache.org>.

YiyangLin commented on issue #497:
URL: https://github.com/apache/rocketmq-client-go/issues/497#issuecomment-699644337


   Same problem here.


----------------------------------------------------------------
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-client-go] maixiaohai commented on issue #497: rocketmq-client-go consumer restart with shutdown and start

Posted by GitBox <gi...@apache.org>.

maixiaohai commented on issue #497:
URL: https://github.com/apache/rocketmq-client-go/issues/497#issuecomment-835832355


   @YiyangLin @navychi This has been fixed.


-- 
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-client-go] YiyangLin edited a comment on issue #497: rocketmq-client-go consumer restart with shutdown and start

Posted by GitBox <gi...@apache.org>.

YiyangLin edited a comment on issue #497:
URL: https://github.com/apache/rocketmq-client-go/issues/497#issuecomment-699644337


   Same problem here.
   ---
   By the way, I temporarily bypass this problem by using WithInstance():
   `rmq.NewPushConsumer(
       ...,
       rmqconsumer.WithInstance(time.Now().Format("15:04:05")), 
   )`


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