apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.3k stars 421 forks source link

Support to run multi consumer in one process #1053

Open cserwen opened 1 year ago

cserwen commented 1 year ago

The Question

The clientId from #778 didn't work for PushConsumer, the rmqClient should be inited after ChangeInstanceNameToPID(). image