synchronized ConsumerSessionImpl get ( long id ) { if ( tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "get" , new Long ( id ) ) ; ConsumerSessionImpl consumer = null ; if ( _messageProcessor . isStarted ( ) ) { consumer = ( ConsumerSessionImpl ) _consumers . get ( new Long ( id ) ) ; } if ( tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "get" , consumer ) ; return consumer ; }
Gets a consumer using its id .