@ Override public void removeReadyConsumer ( JSConsumerKey consumerKey , boolean bSelector ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "removeReadyConsumer" , new Object [ ] { consumerKey , Boolean . valueOf ( bSelector ) } ) ; if ( consumerKey == null ) { SIErrorException e = new SIErrorException ( nls . getFormattedMessage ( "INTERNAL_MESSAGING_ERROR_CWSIP0001" , new Object [ ] { "com.ibm.ws.sib.processor.impl.ConsumerDispatcher" , "1:1684:1.280.5.25" } , null ) ) ; FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.impl.ConsumerDispatcher.removeReadyConsumer" , "1:1690:1.280.5.25" , this ) ; SibTr . exception ( tc , e ) ; SibTr . error ( tc , "INTERNAL_MESSAGING_ERROR_CWSIP0001" , new Object [ ] { "com.ibm.ws.sib.processor.impl.ConsumerDispatcher" , "1:1698:1.280.5.25" } ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "removeReadyConsumer" , e ) ; throw e ; } if ( consumerKey . getForwardScanning ( ) ) { //remove the consumer point from the FS ready list ( ( SimpleEntry ) consumerKey ) . remove ( ) ; } else { if ( bSelector ) { //decrement the specific ready consumer counter specificReadyConsumerCount -- ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( tc , "sepcificReadyConsumerCount:" + specificReadyConsumerCount ) ; } else { //remove the consumer point from the ready list ( ( SimpleEntry ) consumerKey ) . remove ( ) ; } } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "removeReadyConsumer" ) ; }
Remove the ready consumer from our ready lists