Revert "Attempt to connect to additional addresses if fix initiator s…

…ession is unable_to_logon" This reverts commit 53af6f5.
artiofix · Feb 11, 2025 · a0a631a · a0a631a
1 parent 53af6f5
commit a0a631a
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 5 deletions.
diff --git a/artio-core/src/main/java/uk/co/real_logic/artio/library/InitiateSessionReply.java b/artio-core/src/main/java/uk/co/real_logic/artio/library/InitiateSessionReply.java
@@ -25,7 +25,6 @@
 
 import static uk.co.real_logic.artio.GatewayProcess.NO_CONNECTION_ID;
 import static uk.co.real_logic.artio.messages.GatewayError.UNABLE_TO_CONNECT;
-import static uk.co.real_logic.artio.messages.GatewayError.UNABLE_TO_LOGON;
 
 /**
  * .
@@ -71,7 +70,7 @@ protected void sendMessage()
 
     void onError(final GatewayError errorType, final String errorMessage)
     {
-        if (isExecuting() && (errorType == UNABLE_TO_CONNECT || errorType == UNABLE_TO_LOGON))
+        if (errorType == UNABLE_TO_CONNECT)
         {
             addressIndex++;
             register();

diff --git a/...ystem-tests/src/test/java/uk/co/real_logic/artio/system_tests/AsyncAuthenticatorTest.java b/...ystem-tests/src/test/java/uk/co/real_logic/artio/system_tests/AsyncAuthenticatorTest.java
@@ -386,7 +386,7 @@ private void assertDisconnectRejected(final Reply<Session> reply, final boolean
         {
             assertEquals(reply.toString(), Reply.State.ERRORED, reply.state());
             assertThat(reply.error().getMessage(),
-                containsString("Unable to connect to any of the addresses specified"));
+                containsString("UNABLE_TO_LOGON: Disconnected before session active"));
         }
     }
 

diff --git a/...ts/src/test/java/uk/co/real_logic/artio/system_tests/MessageBasedInitiatorSystemTest.java b/...ts/src/test/java/uk/co/real_logic/artio/system_tests/MessageBasedInitiatorSystemTest.java
@@ -509,7 +509,7 @@ private void initiatorFailsToConnect() throws IOException
 
         final Reply<Session> reply = testSystem.awaitReply(this.sessionReply);
         assertEquals(ERRORED, reply.state());
-        assertThat(reply.error().toString(), containsString("Unable to connect to any of the addresses specified"));
+        assertThat(reply.error().toString(), containsString("UNABLE_TO_LOGON"));
     }
 
     private Session completeLogon()

diff --git a/...tests/src/test/java/uk/co/real_logic/artio/system_tests/MultipleConnectionSystemTest.java b/...tests/src/test/java/uk/co/real_logic/artio/system_tests/MultipleConnectionSystemTest.java
@@ -83,7 +83,7 @@ private void failedAuthenticationWithInvalidCompId()
         testSystem.awaitReply(failureReply);
 
         assertEquals(Reply.State.ERRORED, failureReply.state());
-        assertEquals("Unable to connect to any of the addresses specified", failureReply.error().getMessage());
+        assertEquals("UNABLE_TO_LOGON: Disconnected before session active", failureReply.error().getMessage());
     }
 
     @After