public void associateConsumer ( ConsumerSessionProxy consumer ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( this , tc , "associateConsumer" , new Object [ ] { consumer , Boolean . valueOf ( strictRedeliveryOrdering ) } ) ; // This is a no-op if strict redelivery ordering is disabled if ( strictRedeliveryOrdering && consumer != null ) { synchronized ( associatedConsumersLock ) { associatedConsumers . add ( consumer ) ; } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( this , tc , "associateConsumer" ) ; }
Called each time a recoverable message is deleted from a consumer using a proxy queue under this transaction to allow the transaction to callback inform the proxy queue it should purge any read - ahead messages if required .