@Test public void invalidChecksumMessageRecordedWhenBackpressuredPolling() { firstSaveAttemptIsBackPressured(); theEndpointReceivesAMessageWithInvalidChecksum(); assertEquals(-INVALID_CHECKSUM_LEN, endPoint.poll()); pollWithNoData(0); savesInvalidChecksumMessage(times(2)); }
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();  }