aeron-archive/src/main/java/io/aeron/archive/client/AeronArchive.java
public int listRecordingsForUri(
        final long fromRecordingId,
        final int recordCount,
        final String channelFragment,
        final int streamId,
        final RecordingDescriptorConsumer consumer)
    {
        lock.lock();
        try
        {
            ensureOpen();

            final long correlationId = aeron.nextCorrelationId();

            if (!archiveProxy.listRecordingsForUri(
                fromRecordingId,
                recordCount,
                channelFragment,
                streamId,
                correlationId,
                controlSessionId))
            {
                throw new ArchiveException("failed to send list recordings request");
            }

            return pollForDescriptors(correlationId, recordCount, consumer);
        }
        finally
        {
            lock.unlock();
        }
    }
public int listRecordingsForUri(
        final long fromRecordingId,
        final int recordCount,
        final String channelFragment,
        final int streamId,
        final RecordingDescriptorConsumer consumer)
    {
        lock.lock();
        try
        {
            ensureOpen();

            final long correlationId = aeron.nextCorrelationId();

            if (!archiveProxy.listRecordingsForUri(
                fromRecordingId,
                recordCount,
                channelFragment,
                streamId,
                correlationId,
                controlSessionId))
            {
                throw new ArchiveException("failed to send list recordings request");
            }

            return pollForDescriptors(correlationId, recordCount, consumer);
        }
        finally
        {
            lock.unlock();
        }
    }
public int listRecordingsForUri ( final long fromRecordingId , final int recordCount , final String channelFragment , final int streamId , final RecordingDescriptorConsumer consumer ) { lock . lock ( ) ; try { ensureOpen ( ) ; final long correlationId = aeron . nextCorrelationId ( ) ; if ( ! archiveProxy . listRecordingsForUri ( fromRecordingId , recordCount , channelFragment , streamId , correlationId , controlSessionId ) ) { throw new ArchiveException ( "failed to send list recordings request" ) ; } return pollForDescriptors ( correlationId , recordCount , consumer ) ; } finally { lock . unlock ( ) ; } }
List recording descriptors from a recording id with a limit of record count for a given channelFragment and
stream id.
<p>
If the recording id is greater than the largest known id then nothing is returned.

@param fromRecordingId at which to begin the listing.
@param recordCount     to limit for each query.
@param channelFragment for a contains match on the original channel stored with the archive descriptor.
@param streamId        to match.
@param consumer        to which the descriptors are dispatched.
@return the number of descriptors found and consumed.
List recording descriptors from a recording id with a limit of record count for a given channelFragment and stream id . <p > If the recording id is greater than the largest known id then nothing is returned .