public final void consumeAcceptedTick ( TransactionCommon t , AOValue storedTick ) throws Exception { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "consumeAcceptedTick" , storedTick ) ; try { SIMPMessage msg = consumerDispatcher . getMessageByValue ( storedTick ) ; Transaction msTran = mp . resolveAndEnlistMsgStoreTransaction ( t ) ; // PK67067 We may not find a message in the store for this tick, because // it may have been removed using the SIBQueuePoint MBean if ( msg != null ) { msg . remove ( msTran , storedTick . getPLockId ( ) ) ; } storedTick . lockItemIfAvailable ( controlItemLockID ) ; // should always be successful storedTick . remove ( msTran , controlItemLockID ) ; } catch ( Exception e ) { // No FFDC code needed if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "consumeAcceptedTick" , e ) ; throw e ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "consumeAcceptedTick" ) ; }
Helper method called by the AOStream when a persistent tick representing a persistently locked message should be removed since the message has been accepted . This method will also consume the message