replacing asserts with test.await calls

artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/GatewayToGatewaySystemTest.java

@@ -1246,12 +1246,12 @@ public void shouldHandleUserRequestMessages()
  Thread.yield();
  }
 
- assertEquals(PASSWORD, auth.logonPassword());
- assertEquals(PASSWORD, auth.userRequestPassword());
- assertEquals(NEW_PASSWORD, auth.userRequestNewPassword());
- assertEquals(1, auth.sessionId());
+ testSystem.await(() -> PASSWORD.equals(auth.logonPassword()));
+ testSystem.await(() -> PASSWORD.equals(auth.userRequestPassword()));
+ testSystem.await(() -> NEW_PASSWORD.equals(auth.userRequestNewPassword()));
+ testSystem.await(() -> 1 == auth.sessionId());
 
- assertArchiveDoesNotContainPassword();
+ testSystem.await("unexpected result", this::assertArchiveDoesNotContainPassword);
  }
 
  @Test
@@ -1305,7 +1305,7 @@ private void exchangeLargeMessages()
  }
  }
 
- private void assertArchiveDoesNotContainPassword()
+ private boolean assertArchiveDoesNotContainPassword()
  {
  final EngineConfiguration configuration = acceptingEngine.configuration();
 
@@ -1314,10 +1314,12 @@ private void assertArchiveDoesNotContainPassword()
  assertThat(messages, hasSize(greaterThanOrEqualTo(1)));
  for (final String message : messages)
  {
- assertThat(message + " contains the password",
- message,
- allOf(not(containsString(PASSWORD)), not(containsString(NEW_PASSWORD))));
+ if (!allOf(not(containsString(PASSWORD)), not(containsString(NEW_PASSWORD))).matches(message))
+ {
+ return false;
+ }
  }
+ return true;
  }
 
  private void exchangeExecutionReport()