From d9c1014a392d3551d54d2f4de1946fd004a34437 Mon Sep 17 00:00:00 2001 From: marc-adaptive Date: Thu, 29 Aug 2024 21:11:46 -0400 Subject: [PATCH] Formatting --- ...stentSequenceNumberGatewayToGatewaySystemTest.java | 11 ++++++----- .../real_logic/artio/system_tests/SystemTestUtil.java | 10 +++++----- 2 files changed, 11 insertions(+), 10 deletions(-) diff --git a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/PersistentSequenceNumberGatewayToGatewaySystemTest.java b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/PersistentSequenceNumberGatewayToGatewaySystemTest.java index 98166b9f95..32cbed382b 100644 --- a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/PersistentSequenceNumberGatewayToGatewaySystemTest.java +++ b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/PersistentSequenceNumberGatewayToGatewaySystemTest.java @@ -1020,15 +1020,14 @@ private void connectPersistingSessions() @Test(timeout = TEST_TIMEOUT_IN_MS) public void shouldSupportFollowerSessionLogonWithoutSequenceResetOnDisconnectBeforeLibraryLogonResponse() - throws IOException + throws IOException { launch(this::nothing); final List noSessionContext = acceptingEngine.allSessions(); assertEquals(0, noSessionContext.size()); - final SessionWriter sessionWriter = createFollowerSession( - TEST_TIMEOUT_IN_MS, testSystem, acceptingLibrary, INITIATOR_ID, ACCEPTOR_ID); + final SessionWriter sessionWriter = createFollowerSession(TEST_TIMEOUT_IN_MS); final SessionReplyStatus requestSessionReply = requestSession(acceptingLibrary, sessionWriter.id(), testSystem); assertEquals(SessionReplyStatus.OK, requestSessionReply); @@ -1055,8 +1054,10 @@ public void shouldSupportFollowerSessionLogonWithoutSequenceResetOnDisconnectBef } final List allLibraryInfo = libraryReply.resultIfPresent(); - for (final LibraryInfo libraryInfo : allLibraryInfo) { - if (libraryInfo.libraryId() == acceptingLibrary.libraryId()) { + for (final LibraryInfo libraryInfo : allLibraryInfo) + { + if (libraryInfo.libraryId() == acceptingLibrary.libraryId()) + { return libraryInfo.sessions().isEmpty(); } } diff --git a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SystemTestUtil.java b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SystemTestUtil.java index 1eb27e1995..84bc4fc74b 100644 --- a/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SystemTestUtil.java +++ b/artio-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/SystemTestUtil.java @@ -709,13 +709,13 @@ static void awaitIndexerCaughtUp( } static void assertEngineSubscriptionCaughtUpToLibraryPublication( - final TestSystem testSystem, - final String aeronDirectoryName, - final FixEngine engine, - final FixLibrary library) + final TestSystem testSystem, + final String aeronDirectoryName, + final FixEngine engine, + final FixLibrary library) { final EngineStreamInfo engineStreamInfo = - testSystem.awaitCompletedReply(FixEngineInternals.engineStreamInfo(engine)).resultIfPresent(); + testSystem.awaitCompletedReply(FixEngineInternals.engineStreamInfo(engine)).resultIfPresent(); final LibraryStreamInfo libraryStreamInfo = FixLibraryInternals.libraryStreamInfo(library);