diff --git a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/MessageBasedAcceptorSystemTest.java b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/MessageBasedAcceptorSystemTest.java index 8565bec6b5..2e8d00a122 100644 --- a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/MessageBasedAcceptorSystemTest.java +++ b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/MessageBasedAcceptorSystemTest.java @@ -690,6 +690,10 @@ public void shouldSupportReplayingReceivedMessagesAfterReLoginAndReceiveResendRe { reportFactory.sendReport(testSystem, session, Side.BUY); } + while (session.isConnected()) + { + reportFactory.sendReport(testSystem, session, Side.SELL); + } lastSeqNum = connection.msgSeqNum(); assertSessionDisconnected(testSystem, session); @@ -716,14 +720,6 @@ public void shouldSupportReplayingReceivedMessagesAfterReLoginAndReceiveResendRe awaitedMessage(connection, new SequenceResetDecoder()); connection.close(); - try - { - Thread.sleep(200); - } - catch (final InterruptedException e) - { - throw new RuntimeException(e); - } assertSessionDisconnected(testSystem, session); } }