Skip to content

Commit

Permalink
migrate ReceiverEndPointTest to JUnit 5
Browse files Browse the repository at this point in the history
  • Loading branch information
@wojciech-adaptive
wojciech-adaptive committed Dec 20, 2023
1 parent 1386411 commit 076a5b4
Showing 1 changed file with 32 additions and 32 deletions.
64 changes: 32 additions & 32 deletions artio-core/src/test/java/uk/co/real_logic/artio/engine/framer/ReceiverEndPointTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@
import org.agrona.LangUtil;
import org.agrona.concurrent.EpochNanoClock;
import org.agrona.concurrent.status.AtomicCounter;
import org.junit.Before;
import org.junit.Test;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.mockito.InOrder;
import org.mockito.Mockito;
import org.mockito.verification.VerificationMode;
Expand All @@ -43,7 +43,7 @@
import java.util.function.ToIntFunction;

import static io.aeron.Publication.BACK_PRESSURED;
import static org.junit.Assert.*;
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.Mockito.*;
import static uk.co.real_logic.artio.dictionary.ExampleDictionary.TAG_SPECIFIED_OUT_OF_REQUIRED_ORDER_MESSAGE_BYTES;
import static uk.co.real_logic.artio.engine.EngineConfiguration.NO_THROTTLE_WINDOW;
Expand All @@ -54,7 +54,7 @@
import static uk.co.real_logic.artio.session.Session.UNKNOWN;
import static uk.co.real_logic.artio.util.TestMessages.*;

public class ReceiverEndPointTest
class ReceiverEndPointTest
{
private static final long MESSAGE_TYPE = 'D';
private static final long CONNECTION_ID = 20L;
Expand Down Expand Up @@ -101,8 +101,8 @@ private AcceptorLogonResult createBackpressuredPendingAuth()
return pendingAcceptorLogon;
}

@Before
public void setUp()
@BeforeEach
void setUp()
{
givenReceiverEndPoint(SESSION_ID);
when(gatewaySession.session()).thenReturn(session);
Expand Down Expand Up @@ -167,7 +167,7 @@ private void theEndpointReceivesALogon()
}

@Test
public void shouldNotifyDuplicateSession()
void shouldNotifyDuplicateSession()
{
givenAnUnauthenticatedReceiverEndPoint();
givenADuplicateSession();
Expand All @@ -181,7 +181,7 @@ public void shouldNotifyDuplicateSession()
}

@Test
public void shouldDisconnectWhenFirstMessageIsNotALogon()
void shouldDisconnectWhenFirstMessageIsNotALogon()
{
givenAnUnauthenticatedReceiverEndPoint();
givenLogonResult(pendingAuth);
Expand All @@ -195,7 +195,7 @@ public void shouldDisconnectWhenFirstMessageIsNotALogon()
}

@Test
public void shouldFrameValidFixMessage()
void shouldFrameValidFixMessage()
{
theEndpointReceivesACompleteMessage();

Expand All @@ -207,7 +207,7 @@ public void shouldFrameValidFixMessage()
}

@Test
public void shouldDetectOversizedFixMessage()
void shouldDetectOversizedFixMessage()
{
theEndpointReceivesTheStartOfAnOversizedMessage();

Expand All @@ -221,7 +221,7 @@ public void shouldDetectOversizedFixMessage()
}

@Test
public void shouldFrameValidFixMessageWhenBackpressuredSelectionKeyCase()
void shouldFrameValidFixMessageWhenBackpressuredSelectionKeyCase()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -236,7 +236,7 @@ public void shouldFrameValidFixMessageWhenBackpressuredSelectionKeyCase()
}

@Test
public void shouldFrameValidFixMessageWhenBackpressuredPollingCase()
void shouldFrameValidFixMessageWhenBackpressuredPollingCase()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -252,7 +252,7 @@ public void shouldFrameValidFixMessageWhenBackpressuredPollingCase()
}

@Test
public void shouldIgnoreMessageWithBodyLengthTooShort()
void shouldIgnoreMessageWithBodyLengthTooShort()
{
final int length = INVALID_LENGTH_MESSAGE.length;
theEndpointReceives(INVALID_LENGTH_MESSAGE, 0, length);
Expand All @@ -268,7 +268,7 @@ public void shouldIgnoreMessageWithBodyLengthTooShort()
}

@Test
public void shouldOnlyFrameCompleteFixMessage()
void shouldOnlyFrameCompleteFixMessage()
{
theEndpointReceivesAnIncompleteMessage();

Expand All @@ -278,7 +278,7 @@ public void shouldOnlyFrameCompleteFixMessage()
}

@Test
public void shouldFrameSplitFixMessage()
void shouldFrameSplitFixMessage()
{
theEndpointReceivesAnIncompleteMessage();
endPoint.poll();
Expand All @@ -292,7 +292,7 @@ public void shouldFrameSplitFixMessage()
}

@Test
public void shouldFrameTwoCompleteFixMessagesInOnePacket()
void shouldFrameTwoCompleteFixMessagesInOnePacket()
{
theEndpointReceivesTwoCompleteMessages();

Expand All @@ -304,7 +304,7 @@ public void shouldFrameTwoCompleteFixMessagesInOnePacket()
}

@Test
public void shouldFrameOneCompleteMessageWhenTheSecondMessageIsIncomplete()
void shouldFrameOneCompleteMessageWhenTheSecondMessageIsIncomplete()
{
theEndpointReceivesACompleteAndAnIncompleteMessage();

Expand All @@ -316,7 +316,7 @@ public void shouldFrameOneCompleteMessageWhenTheSecondMessageIsIncomplete()
}

@Test
public void shouldFrameSecondSplitMessage()
void shouldFrameSecondSplitMessage()
{
theEndpointReceivesACompleteAndAnIncompleteMessage();
endPoint.poll();
Expand All @@ -330,7 +330,7 @@ public void shouldFrameSecondSplitMessage()
}

@Test
public void aClosedSocketSavesItsDisconnect() throws IOException
void aClosedSocketSavesItsDisconnect() throws IOException
{
theChannelIsClosedByException();

Expand All @@ -341,7 +341,7 @@ public void aClosedSocketSavesItsDisconnect() throws IOException
}

@Test
public void anUnreadableSocketDisconnectsItsSession() throws IOException
void anUnreadableSocketDisconnectsItsSession() throws IOException
{
theChannelIsClosed();

Expand All @@ -351,7 +351,7 @@ public void anUnreadableSocketDisconnectsItsSession() throws IOException
}

@Test
public void invalidChecksumMessageRecorded()
void invalidChecksumMessageRecorded()
{
theEndpointReceivesAMessageWithInvalidChecksum();

Expand All @@ -365,7 +365,7 @@ public void invalidChecksumMessageRecorded()
}

@Test
public void invalidChecksumMessageRecordedWhenBackpressuredPolling()
void invalidChecksumMessageRecordedWhenBackpressuredPolling()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -379,7 +379,7 @@ public void invalidChecksumMessageRecordedWhenBackpressuredPolling()
}

@Test
public void invalidChecksumMessageRecordedWhenBackpressuredSelectionKey()
void invalidChecksumMessageRecordedWhenBackpressuredSelectionKey()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -393,7 +393,7 @@ public void invalidChecksumMessageRecordedWhenBackpressuredSelectionKey()
}

@Test
public void fieldOutOfOrderMessageRecordedOnce()
void fieldOutOfOrderMessageRecordedOnce()
{
theEndpointReceivesAnOutOfOrderMessage(OUT_OF_REQUIRED_ORDER_MSG_LEN);

Expand All @@ -406,7 +406,7 @@ public void fieldOutOfOrderMessageRecordedOnce()
}

@Test
public void fieldOutOfOrderMessageRecordedWhenBackpressured()
void fieldOutOfOrderMessageRecordedWhenBackpressured()
{
firstSaveAttemptIsBackPressured();
theEndpointReceivesAnOutOfOrderMessage(-OUT_OF_REQUIRED_ORDER_MSG_LEN);
Expand All @@ -418,7 +418,7 @@ public void fieldOutOfOrderMessageRecordedWhenBackpressured()
}

@Test
public void shouldFrameSplitFixMessageWhenBackpressured()
void shouldFrameSplitFixMessageWhenBackpressured()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -436,7 +436,7 @@ public void shouldFrameSplitFixMessageWhenBackpressured()
}

@Test
public void shouldFrameTwoCompleteFixMessagesInOnePacketWhenBackpressured()
void shouldFrameTwoCompleteFixMessagesInOnePacketWhenBackpressured()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -452,7 +452,7 @@ public void shouldFrameTwoCompleteFixMessagesInOnePacketWhenBackpressured()
}

@Test
public void shouldFrameOneCompleteMessageWhenTheSecondMessageIsIncompleteWhenBackpressured()
void shouldFrameOneCompleteMessageWhenTheSecondMessageIsIncompleteWhenBackpressured()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -465,7 +465,7 @@ public void shouldFrameOneCompleteMessageWhenTheSecondMessageIsIncompleteWhenBac
}

@Test
public void shouldFrameSecondSplitMessageWhenBackpressured()
void shouldFrameSecondSplitMessageWhenBackpressured()
{
firstSaveAttemptIsBackPressured();

Expand All @@ -481,7 +481,7 @@ public void shouldFrameSecondSplitMessageWhenBackpressured()
}

@Test
public void shouldFrameLogonMessageWhenLoggerBehind()
void shouldFrameLogonMessageWhenLoggerBehind()
{
givenAnUnauthenticatedReceiverEndPoint();
givenLogonResult(backpressuredPendingAuth);
Expand Down Expand Up @@ -530,13 +530,13 @@ private void polls(final int bytesReadAndSaved)
private void verifyNoError()
{
verify(errorHandler, never()).onError(any());
assertFalse("Endpoint Disconnected", endPoint.hasDisconnected());
assertFalse(endPoint.hasDisconnected(), "Endpoint Disconnected");
}

private void verifyError(final VerificationMode mode)
{
verify(errorHandler, mode).onError(any());
assertTrue("Endpoint Disconnected", endPoint.hasDisconnected());
assertTrue(endPoint.hasDisconnected(), "Endpoint Connected");
}

private void savesInvalidOutOfRequiredMessage(final VerificationMode mode, final long timestamp)
Expand Down

0 comments on commit 076a5b4

Please sign in to comment.