ARTEMIS-3685 Fix BridgeImpl init

apache · Feb 28, 2022 · 263351b · 263351b
1 parent c4ebccd
commit 263351b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java b/...server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/BridgeImpl.java
@@ -162,6 +162,8 @@ public BridgeImpl(final ServerLocatorInternal serverLocator,
 
       this.configuration = configuration;
 
+      this.reconnectAttemptsInUse = configuration.getInitialConnectAttempts();
+
       this.serverLocator = serverLocator;
 
       this.nodeUUID = nodeUUID;

diff --git a/...in/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java b/...in/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionBridge.java
@@ -53,7 +53,6 @@
 import org.apache.activemq.artemis.core.server.cluster.ClusterConnection;
 import org.apache.activemq.artemis.core.server.cluster.ClusterManager;
 import org.apache.activemq.artemis.core.server.cluster.MessageFlowRecord;
-import org.apache.activemq.artemis.core.server.transformer.Transformer;
 import org.apache.activemq.artemis.utils.CompositeAddress;
 import org.apache.activemq.artemis.utils.UUID;
 import org.apache.activemq.artemis.utils.UUIDGenerator;