@Test(timeout = 20_000L) public void shouldUpdatePositionForIndexedRecord() { indexExampleMessage(); positionReader.readLastPosition(positionConsumer); final int aeronSessionId = publication.sessionId(); final long recordingId = recordingIdLookup.getRecordingId(aeronSessionId); verify(positionConsumer, times(1)) .accept(aeronSessionId, recordingId, alignedEndPosition()); }
public void readLastPosition(final IndexedPositionConsumer consumer) { positionReader.readLastPosition(consumer); }
ReplayIndex implements Index { public void readLastPosition(final IndexedPositionConsumer consumer) { positionReader.readLastPosition(consumer); } }
ReplayIndex implements Index { public void readLastPosition(final IndexedPositionConsumer consumer) { positionReader.readLastPosition(consumer); } ReplayIndex(
        final String logFileDir,
        final int requiredStreamId,
        final int indexFileSize,
        final int cacheNumSets,
        final int cacheSetSize,
        final BufferFactory bufferFactory,
        final AtomicBuffer positionBuffer,
        final ErrorHandler errorHandler,
        final RecordingIdLookup recordingIdLookup,
        final Long2LongHashMap connectionIdToILinkUuid); }
ReplayIndex implements Index { public void readLastPosition(final IndexedPositionConsumer consumer) { positionReader.readLastPosition(consumer); } ReplayIndex(
        final String logFileDir,
        final int requiredStreamId,
        final int indexFileSize,
        final int cacheNumSets,
        final int cacheSetSize,
        final BufferFactory bufferFactory,
        final AtomicBuffer positionBuffer,
        final ErrorHandler errorHandler,
        final RecordingIdLookup recordingIdLookup,
        final Long2LongHashMap connectionIdToILinkUuid); void onCatchup(
        final DirectBuffer buffer,
        final int offset,
        final int length,
        final Header header,
        final long recordingId); void onFragment(
        final DirectBuffer buffer,
        final int offset,
        final int length,
        final Header header); void onFragment(
        final DirectBuffer srcBuffer,
        final int srcOffset,
        final int srcLength,
        final Header header,
        final long recordingId); int doWork(); void close(); void readLastPosition(final IndexedPositionConsumer consumer); }
ReplayIndex implements Index { public void readLastPosition(final IndexedPositionConsumer consumer) { positionReader.readLastPosition(consumer); } ReplayIndex(
        final String logFileDir,
        final int requiredStreamId,
        final int indexFileSize,
        final int cacheNumSets,
        final int cacheSetSize,
        final BufferFactory bufferFactory,
        final AtomicBuffer positionBuffer,
        final ErrorHandler errorHandler,
        final RecordingIdLookup recordingIdLookup,
        final Long2LongHashMap connectionIdToILinkUuid); void onCatchup(
        final DirectBuffer buffer,
        final int offset,
        final int length,
        final Header header,
        final long recordingId); void onFragment(
        final DirectBuffer buffer,
        final int offset,
        final int length,
        final Header header); void onFragment(
        final DirectBuffer srcBuffer,
        final int srcOffset,
        final int srcLength,
        final Header header,
        final long recordingId); int doWork(); void close(); void readLastPosition(final IndexedPositionConsumer consumer);  }