Skip to content

Commit

Permalink
[Java] Fix checkstyle.
Browse files Browse the repository at this point in the history
  • Loading branch information
mikeb01 committed Dec 28, 2023
1 parent 0bc5b7e commit 253ccf6
Showing 1 changed file with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,6 @@
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotEquals;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

@ExtendWith(InterruptingTestCallback.class)
public class ResponseChannelsTest
Expand All @@ -68,8 +67,6 @@ public class ResponseChannelsTest
@BeforeEach
void setUp()
{
// assumeTrue(TestMediaDriver.shouldRunJavaMediaDriver());

driver = TestMediaDriver.launch(new MediaDriver.Context()
.publicationTermBufferLength(LogBufferDescriptor.TERM_MIN_LENGTH)
.threadingMode(ThreadingMode.SHARED),
Expand Down Expand Up @@ -130,7 +127,7 @@ void shouldReceiveResponsesOnAPerClientBasis() throws Exception
while (0 > responseClientB.offer(messageB))
{
idleStrategy.idle(run(responseServer, responseClientA, responseClientB));
Tests.checkInterruptStatus("unable to offer message to client A");
Tests.checkInterruptStatus("unable to offer message to client B");
}

while (!responsesA.contains(textA) || !responsesB.contains(textB))
Expand All @@ -139,8 +136,8 @@ void shouldReceiveResponsesOnAPerClientBasis() throws Exception
Tests.checkInterruptStatus("failed to receive responses");
}

assertEquals(1, responsesA.size());
assertEquals(1, responsesB.size());
assertEquals(1, responsesA.size(), "A=" + responsesA + ", B=" + responsesB);
assertEquals(1, responsesB.size(), "A=" + responsesA + ", B=" + responsesB);
}
}

Expand Down

0 comments on commit 253ccf6

Please sign in to comment.