mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-19 02:23:24 +08:00
* feature: 1.add replicasManager and controllerProxy * feature: 1.add brokerHaAddress in controller. * feature: 1.add replicasManager * feature: 1.add brokerController to replicasManager. 2.change brokerController when change role. * feature: add api message empty constructor * feature: move set from header to remotingRequest body * feature: modify autoSwitchHaClient's rpc protocol, add slaveId, slaveAddress. * feature: review code * feature: review code * add some debug info * feature: let ha service get masterHaAdress after register to name-srv * feature: review code xxxx * feature: let controller return err remark * style: review * style: review code * feature: add more integrationTest * style: review code * style: review code * fix: port already bind