@ Override public void checkForMessages ( ) { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "checkForMessages" , this ) ; try { //start a new thread to run the callback _messageProcessor . startNewThread ( new AsynchThread ( this , false ) ) ; } catch ( InterruptedException e ) { FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint.checkForMessages" , "1:3881:1.22.5.1" , this ) ; SibTr . exception ( tc , e ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "checkForMessages" , e ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "checkForMessages" ) ; }
Spin off a thread that checks for any stored messages . This is called by a consumerKeyGroup to try to kick a group back into life after a stopped member detaches and makes the group ready again .