This is an automated email from the ASF dual-hosted git repository. gtully pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 1dc9d4f45589a1e8d2565e23fb8cd0321241f6e9 Author: franz1981 <[email protected]> AuthorDate: Fri Sep 24 09:00:43 2021 +0200 ARTEMIS-3496 Replica connection to its live should fail fast --- .../activemq/artemis/core/server/impl/ReplicationBackupActivation.java | 2 +- .../artemis/core/server/impl/SharedNothingBackupActivation.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ReplicationBackupActivation.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ReplicationBackupActivation.java index 10212e0..35f5afe 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ReplicationBackupActivation.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ReplicationBackupActivation.java @@ -566,7 +566,7 @@ public final class ReplicationBackupActivation extends Activation implements Dis final ReplicationObserver liveObserver) { ReplicationEndpoint replicationEndpoint = null; try { - liveControl.getSessionFactory().setReconnectAttempts(1); + liveControl.getSessionFactory().setReconnectAttempts(0); liveObserver.listenConnectionFailuresOf(liveControl.getSessionFactory()); liveControl.authorize(); replicationEndpoint = new ReplicationEndpoint(activeMQServer, policy.isTryFailback(), liveObserver); diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java index 13421c8..85cbed6 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingBackupActivation.java @@ -498,7 +498,7 @@ public final class SharedNothingBackupActivation extends Activation implements R public void run() { try { //we should only try once, if its not there we should move on. - clusterControl.getSessionFactory().setReconnectAttempts(1); + clusterControl.getSessionFactory().setReconnectAttempts(0); backupQuorum.setSessionFactory(clusterControl.getSessionFactory()); //get the connection and request replication to live clusterControl.authorize();
