Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-3198 Fixing test after concurrency bridge changes

This commit is contained in:
Clebert Suconic 2021-03-22 21:56:02 -04:00
parent 04fcecb579
commit 31345c5b51
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterManager.java
View File

@ -476,7 +476,7 @@ public final class ClusterManager implements ActiveMQComponent {
clusterLocators.add(serverLocator); clusterLocators.add(serverLocator);
for (int i = 0; i < config.getConcurrency(); i++) { for (int i = 0; i < config.getConcurrency(); i++) {
String name = (config.getName() + "-" + i); String name = config.getConcurrency() > 1 ? (config.getName() + "-" + i) : config.getName();
Bridge bridge = new BridgeImpl(serverLocator, config.getInitialConnectAttempts(), config.getReconnectAttempts(), Bridge bridge = new BridgeImpl(serverLocator, config.getInitialConnectAttempts(), config.getReconnectAttempts(),
config.getReconnectAttemptsOnSameNode(), config.getRetryInterval(), config.getRetryIntervalMultiplier(), config.getReconnectAttemptsOnSameNode(), config.getRetryInterval(), config.getRetryIntervalMultiplier(),
config.getMaxRetryInterval(), nodeManager.getUUID(), new SimpleString(name), queue, config.getMaxRetryInterval(), nodeManager.getUUID(), new SimpleString(name), queue,