public void registerProcessForMessage ( BaseMessageFilter messageFilter , String strProcessClass , Map < String , Object > properties ) { new TrxMessageListener ( messageFilter , ( Application ) this . getTask ( ) . getApplication ( ) , strProcessClass , properties ) ; // This listener was added to the filter ( ( MessageInfoApplication ) this . getTask ( ) . getApplication ( ) ) . getThickMessageManager ( ) . addMessageFilter ( messageFilter ) ; // Note: No need to worry about cleanup... Freeing the message manager will free all these listeners. if ( properties != null ) if ( properties . get ( MessageInfoApplication . AUTOSTART ) != null ) ( ( MessageInfoApplication ) this . getTask ( ) . getApplication ( ) ) . getThickMessageManager ( ) . sendMessage ( new MapMessage ( new BaseMessageHeader ( messageFilter . getQueueName ( ) , messageFilter . getQueueType ( ) , this , null ) , properties ) ) ; }
RegisterProcessForMessage Method .