private void processEvent ( NFAState nfaState , IN event , long timestamp ) throws Exception { try ( SharedBufferAccessor < IN > sharedBufferAccessor = partialMatches . getAccessor ( ) ) { Collection < Map < String , List < IN > > > patterns = nfa . process ( sharedBufferAccessor , nfaState , event , timestamp , afterMatchSkipStrategy , cepTimerService ) ; processMatchedSequences ( patterns , timestamp ) ; } }
Process the given event by giving it to the NFA and outputting the produced set of matched event sequences .