public static boolean isCommittedProcessed ( byte [ ] stateBytes , Transaction tx ) { long writePointer = Bytes . toLong ( stateBytes , 0 , Longs . BYTES ) ; if ( ! tx . isVisible ( writePointer ) ) { return false ; } byte state = stateBytes [ Longs . BYTES + Ints . BYTES ] ; return state == ConsumerEntryState . PROCESSED . getState ( ) ; }
For a queue entry consumer state serialized to byte array return whether it is processed and committed .