opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #4832] Remove innerProducer and innerConsumer in EscapeBridge (#4834)

Browse Source 
* remove innerProducer and innerConsumer in Escape
 #4832

* format code to pass code-style check

* Move topic route management logic to TopicRouteInfoManager

* Use ThreadPoolExecutor instead of creating a new ForkJoinPool

* remove retry logic

* remove unnecessary name server list

* remove unnecessary invokeId

* remove AssignmentManager and make maintenance of topic subscribe data lazy-initialized

* simply code

* remove unnecessary code
This commit is contained in:
caigy
2022-08-24 15:18:51 +08:00
committed by GitHub
parent cf3c1ef57f
commit 10d291846e
10 changed files with 597 additions and 291 deletions
Download Patch File Download Diff File Expand all files Collapse all files
container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java
-11
View File
@@ -133,17 +133,6 @@ public class InnerBrokerController extends BrokerController {
return this.brokerConfig.getBrokerIP1() + ":" + this.brokerConfig.getListenPort();
}
@Override
public String getNameServerList() {
if (this.brokerContainer.getBrokerContainerConfig().getNamesrvAddr() != null) {
this.brokerContainer.getBrokerOuterAPI().updateNameServerAddressList(brokerContainer.getBrokerContainerConfig().getNamesrvAddr());
return this.brokerContainer.getBrokerContainerConfig().getNamesrvAddr();
} else if (this.brokerContainer.getBrokerContainerConfig().isFetchNamesrvAddrByAddressServer()) {
return this.brokerContainer.getBrokerOuterAPI().fetchNameServerAddr();
}
return null;
}
@Override
public String getHAServerAddr() {
return this.brokerConfig.getBrokerIP2() + ":" + this.messageStoreConfig.getHaListenPort();