public BaseMessageFilter createDefaultFilter ( JMessageListener listener ) { BaseMessageFilter messageFilter = null ; String strQueueName = MessageConstants . RECORD_QUEUE_NAME ; // Default queue name= String strQueueType = MessageConstants . INTRANET_QUEUE ; // Default queue type if ( m_baseMessageQueue != null ) { strQueueName = m_baseMessageQueue . getQueueName ( ) ; strQueueType = m_baseMessageQueue . getQueueType ( ) ; } messageFilter = new BaseMessageFilter ( strQueueName , strQueueType , null , null ) ; // Take all messages messageFilter . addMessageListener ( listener ) ; //xif (bAddToReceiver) // Already added at previous line. //x this.addMessageFilter(messageFilter); return messageFilter ; }
Create a message filter that will send all messages to this listener .