aeron-archive/src/main/java/io/aeron/archive/client/AeronArchive.java
public int listRecordingSubscriptions(
        final int pseudoIndex,
        final int subscriptionCount,
        final String channelFragment,
        final int streamId,
        final boolean applyStreamId,
        final RecordingSubscriptionDescriptorConsumer consumer)
    {
        lock.lock();
        try
        {
            ensureOpen();

            final long correlationId = aeron.nextCorrelationId();

            if (!archiveProxy.listRecordingSubscriptions(
                pseudoIndex,
                subscriptionCount,
                channelFragment,
                streamId,
                applyStreamId,
                correlationId,
                controlSessionId))
            {
                throw new ArchiveException("failed to send list recording subscriptions request");
            }

            return pollForSubscriptionDescriptors(correlationId, subscriptionCount, consumer);
        }
        finally
        {
            lock.unlock();
        }
    }
public int listRecordingSubscriptions(
        final int pseudoIndex,
        final int subscriptionCount,
        final String channelFragment,
        final int streamId,
        final boolean applyStreamId,
        final RecordingSubscriptionDescriptorConsumer consumer)
    {
        lock.lock();
        try
        {
            ensureOpen();

            final long correlationId = aeron.nextCorrelationId();

            if (!archiveProxy.listRecordingSubscriptions(
                pseudoIndex,
                subscriptionCount,
                channelFragment,
                streamId,
                applyStreamId,
                correlationId,
                controlSessionId))
            {
                throw new ArchiveException("failed to send list recording subscriptions request");
            }

            return pollForSubscriptionDescriptors(correlationId, subscriptionCount, consumer);
        }
        finally
        {
            lock.unlock();
        }
    }
public int listRecordingSubscriptions ( final int pseudoIndex , final int subscriptionCount , final String channelFragment , final int streamId , final boolean applyStreamId , final RecordingSubscriptionDescriptorConsumer consumer ) { lock . lock ( ) ; try { ensureOpen ( ) ; final long correlationId = aeron . nextCorrelationId ( ) ; if ( ! archiveProxy . listRecordingSubscriptions ( pseudoIndex , subscriptionCount , channelFragment , streamId , applyStreamId , correlationId , controlSessionId ) ) { throw new ArchiveException ( "failed to send list recording subscriptions request" ) ; } return pollForSubscriptionDescriptors ( correlationId , subscriptionCount , consumer ) ; } finally { lock . unlock ( ) ; } }
List active recording subscriptions in the archive. These are the result of requesting one of
{@link #startRecording(String, int, SourceLocation)} or a
{@link #extendRecording(long, String, int, SourceLocation)}. The returned subscription id can be used for
passing to {@link #stopRecording(long)}.

@param pseudoIndex       in the active list at which to begin for paging.
@param subscriptionCount to get in a listing.
@param channelFragment   to do a contains match on the stripped channel URI. Empty string is match all.
@param streamId          to match on the subscription.
@param applyStreamId     true if the stream id should be matched.
@param consumer          for the matched subscription descriptors.
@return the count of matched subscriptions.
List active recording subscriptions in the archive . These are the result of requesting one of { @link #startRecording ( String int SourceLocation ) } or a { @link #extendRecording ( long String int SourceLocation ) } . The returned subscription id can be used for passing to { @link #stopRecording ( long ) } .