Attempt to connect to additional addresses if fix initiator session is unable_to_logon

Author: marc-adaptive

artio-core/src/main/java/uk/co/real_logic/artio/library/InitiateSessionReply.java

@@ -25,6 +25,7 @@
 
 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;
 
 /**
  * .
@@ -70,7 +71,7 @@ protected void sendMessage()
 
     void onError(final GatewayError errorType, final String errorMessage)
     {
-        if (errorType == UNABLE_TO_CONNECT)
+        if (isExecuting() && (errorType == UNABLE_TO_CONNECT || errorType == UNABLE_TO_LOGON))
         {
             addressIndex++;
             register();

artio-system-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_LOGON: Disconnected before session active"));
+                containsString("Unable to connect to any of the addresses specified"));
         }
     }
 

artio-system-tests/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_LOGON"));
+        assertThat(reply.error().toString(), containsString("Unable to connect to any of the addresses specified"));
     }
 
     private Session completeLogon()

artio-system-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_LOGON: Disconnected before session active", failureReply.error().getMessage());
+        assertEquals("Unable to connect to any of the addresses specified", failureReply.error().getMessage());
     }
 
     @After