@Test public void shouldIgnoreMessageWithBodyLengthTooShort() { final int length = INVALID_LENGTH_MESSAGE.length; theEndpointReceives(INVALID_LENGTH_MESSAGE, 0, length); endPoint.poll(); savesInvalidMessage(length, times(1), INVALID_BODYLENGTH, TIMESTAMP); verifyNoError(); verifyNotDisconnected(); sessionReceivesNoMessages(); shouldFrameValidFixMessage(); }
abstract int poll();
ReceiverEndPoint { abstract int poll(); }
ReceiverEndPoint { abstract int poll(); ReceiverEndPoint(
        final GatewayPublication publication,
        final TcpChannel channel,
        final long connectionId,
        final int bufferSize,
        final ErrorHandler errorHandler,
        final Framer framer,
        final int libraryId); }
ReceiverEndPoint { abstract int poll(); ReceiverEndPoint(
        final GatewayPublication publication,
        final TcpChannel channel,
        final long connectionId,
        final int bufferSize,
        final ErrorHandler errorHandler,
        final Framer framer,
        final int libraryId); void libraryId(final int libraryId); int libraryId(); }
ReceiverEndPoint { abstract int poll(); ReceiverEndPoint(
        final GatewayPublication publication,
        final TcpChannel channel,
        final long connectionId,
        final int bufferSize,
        final ErrorHandler errorHandler,
        final Framer framer,
        final int libraryId); void libraryId(final int libraryId); int libraryId();  }