public void stopReplay ( final long replaySessionId ) { lock . lock ( ) ; try { ensureOpen ( ) ; final long correlationId = aeron . nextCorrelationId ( ) ; if ( ! archiveProxy . stopReplay ( replaySessionId , correlationId , controlSessionId ) ) { throw new ArchiveException ( "failed to send stop replay request" ) ; } pollForResponse ( correlationId ) ; } finally { lock . unlock ( ) ; } }
Stop a replay session .