private boolean isApplicable(QueryCacheEventData event) {
        if (!getInfo().isPublishable()) {
            return false;
        }

        final int partitionId = event.getPartitionId();

        if (isEndEvent(event)) {
            sequenceProvider.reset(partitionId);
            removeFromBrokenSequences(event);
            return false;
        }

        if (isNextEvent(event)) {
            long currentSequence = sequenceProvider.getSequence(partitionId);
            sequenceProvider.compareAndSetSequence(currentSequence, event.getSequence(), partitionId);

            removeFromBrokenSequences(event);
            return true;
        }

        handleUnexpectedEvent(event);

        return false;
    }
private boolean isApplicable ( QueryCacheEventData event ) { if ( ! getInfo ( ) . isPublishable ( ) ) { return false ; } final int partitionId = event . getPartitionId ( ) ; if ( isEndEvent ( event ) ) { sequenceProvider . reset ( partitionId ) ; removeFromBrokenSequences ( event ) ; return false ; } if ( isNextEvent ( event ) ) { long currentSequence = sequenceProvider . getSequence ( partitionId ) ; sequenceProvider . compareAndSetSequence ( currentSequence , event . getSequence ( ) , partitionId ) ; removeFromBrokenSequences ( event ) ; return true ; } handleUnexpectedEvent ( event ) ; return false ; }
Checks whether the event data is applicable to the query cache.