private boolean hasBacklog ( ) { final long cursor = ringBuffer . getCursor ( ) ; for ( final Sequence consumer : consumerRepository . getLastSequenceInChain ( false ) ) { if ( cursor > consumer . get ( ) ) { return true ; } } return false ; }
Confirms if all messages have been consumed by all event processors