protected void dispatchMessage ( Message message ) { _messagesIn ++ ; // count 'em up! // we dispatch to a message dispatcher that is specialized for the particular class of // message that we received MessageDispatcher disp = _disps . get ( message . getClass ( ) ) ; if ( disp == null ) { log . warning ( "No dispatcher for message" , "msg" , message ) ; return ; } // otherwise pass the message on to the dispatcher disp . dispatch ( this , message ) ; }
Processes a message without throttling .