@ Override public long newReadyConsumer ( JSConsumerKey consumerKey , boolean bSelector ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "newReadyConsumer" , new Object [ ] { consumerKey , Boolean . valueOf ( bSelector ) } ) ; // If this is a forward scanning consumer just remember we have one if ( consumerKey . getForwardScanning ( ) ) { //move the consumerPoint in to the ready list readyFwdScanningCPs . put ( ( SimpleEntry ) consumerKey ) ; } else { // If the consumer has a selector... if ( bSelector ) { //increment the specific consumer count and the version number specificReadyConsumerCount ++ ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isDebugEnabled ( ) ) SibTr . debug ( tc , "sepcificReadyConsumerCount:" + specificReadyConsumerCount ) ; } else { //move the consumerPoint in to the ready list nonSpecificReadyCPs . put ( ( SimpleEntry ) consumerKey ) ; } } // Increment the ready version ++ readyConsumerVersion ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "newReadyConsumer" , Long . valueOf ( readyConsumerVersion ) ) ; return readyConsumerVersion ; }
Add a ready consumer into our ready lists