From 31345c5b51c1d8fd309708128eb160382c0c3f34 Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Mon, 22 Mar 2021 21:56:02 -0400 Subject: [PATCH] ARTEMIS-3198 Fixing test after concurrency bridge changes --- .../activemq/artemis/core/server/cluster/ClusterManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterManager.java index 05008d0244..14d4af0b93 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterManager.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterManager.java @@ -476,7 +476,7 @@ public final class ClusterManager implements ActiveMQComponent { clusterLocators.add(serverLocator); 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(), config.getReconnectAttemptsOnSameNode(), config.getRetryInterval(), config.getRetryIntervalMultiplier(), config.getMaxRetryInterval(), nodeManager.getUUID(), new SimpleString(name), queue,