MDB: Message id is null Error

Greenhorn

Posts: 13

posted 12 years ago

Number of slices to send:

Optional 'thank-you' note:

Send

Hi,
In our application we are using Jboss Message Queue and the MDB's for message processing. The MDB's will process the request (Queue) and sends the reponse.(publishes to topic).
But after processing each message by the onMessage, "Message id is null" Error message is getting displayed in the jboss console (linux m/c). The functionalities are working fine but the only problem is this error message.
So we do not want to get this error message displayed. Could you please help me out in resolving this issue .

We are using jboss-5.1.0.GA as Application server.

Jboss console Logs:

15:11:18,490 INFO  [EventHandlerMDB] 00008719:com.sdp.mdb.EventHandlerMDB: CgrEvent: 1: (SessionInitReq), CgrCorID:00008719, CgrIMSI:621019980000301, IPAddress :, MccMnc:0, Realm:postpaid.abc.com, AcctInputOctets :0, AcctOutputOctets:0  
15:11:18,523 INFO  [EventHandlerMDB] 00008719:com.sdp.mdb.EventHandlerMDB::onMessage: Firing the Rules for Event:1 (SessionInitReq) , State :1 (IDLE), OperatorId=2 and StateMachineId:1  
15:11:18,631 INFO  [EventHandlerMDB] 00008719:com.sdp.sdpResponse.SDPResponse :: sendSDPResponseToCGR : IMSI=621019980000301, Event=11, EventName =SessionInitResponse, IpPool=secondary_pool, QuotaVolume =0.0, QuotaId=0  
15:11:39,850 ERROR [AbstractDLQHandler] Message id is null? delegator->JBossMessage[21598599575093255]:PERSISTENT, deliveryId=6  
15:11:39,851 INFO  [EventHandlerMDB] 00008719:com.sdp.mdb.EventHandlerMDB: CgrEvent: 2: (Connected), CgrCorID:00008719, CgrIMSI:621019980000301, IPAddress :10.0.0.160, MccMnc:40486, Realm:postpaid.abc.com, AcctInputOctets :0, AcctOutputOctets:0

Jboss server Log:

Source Code for Reference:
EventHandlerMDB.java
This class is used for processing the message from Queue and to send the response.(publish it to the topic)

package com.sdp.mdb;

@MessageDriven(mappedName = SDPConstants.SDP_QUEUE_NAME, activationConfig = {
		@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
		@ActivationConfigProperty(propertyName = "destination", propertyValue = SDPConstants.SDP_QUEUE_NAME),
		@ActivationConfigProperty(propertyName= "maxSession", propertyValue=SDPConstants.MDB_POOL_SIZE_STRING),
		@ActivationConfigProperty(propertyName= "transactionTimeout", propertyValue="1500")

})
@Pool(value=PoolDefaults.POOL_IMPLEMENTATION_STRICTMAX, maxSize=SDPConstants.MDB_POOL_SIZE_INT, timeout=10000)	
public class EventHandlerMDB implements MessageListener {
	private static final Logger logger = Logger.getLogger(EventHandlerMDB.class.getName());
	private StatefulKnowledgeSession ksession=null;
	private UserInfoDao userInfoDaoObj=null;
	
	public EventHandlerMDB() {

logger.info(this.getClass().getName()+" - Dao and Drools Instantiation Begin.");
			
			/*Instantiating Dao Classes in the MDB Constructor.*/
			
			 userInfoDaoObj 		= new UserInfoDao();
			
			 sdpResponseObj			= new SDPResponse(); //Instantiate SDResponse. It will also do the Topic configuration.
			 
			 DroolsKnowlwdgeBase droolsObj =new DroolsKnowlwdgeBase();
			 KnowledgeBase kbase=null;
			 
			 try {
				//Reading SdpStateMachine.xls file
				kbase = droolsObj.readKnowledgeBase(); 
				
				//Getting Drools Knowledge Base Session
				ksession = kbase.newStatefulKnowledgeSession();
				
			} catch (Exception e) {
				logger.error(this.getClass().getName()+" : Constructor: KnowledgeBase  instantiation failed !!");	
			}

}

public void onMessage(Message message) {
		
		try {
			if (message != null) {
				
				//Checking whether the message  is an object message
				if (message instanceof ObjectMessage) {        
					
					ObjectMessage objMsg = (ObjectMessage) message; 
					
					/*Parsing input object message to the CGR Message*/
					CGRMessage cgrMsgObj = (CGRMessage) objMsg.getObject();
					
					////logic goes here......
					//
					//send response to Topic
				}
                       }
                 }catch (Exception e) {
			logger.error(this.getClass().getName()+":: onMessage: Message Processing failed !!");
		}

RadiusJMS.java
This class is used for sending messages to the queue and for listening to the reponse published to topic.

SendJmsEvents.java
This class actually sends the message to the queue

public class SendJmsEvents {
	static QueueConnection conn;
	static QueueSession session;
	static Queue que;
	
	public static void setupConnection() throws JMSException, NamingException {
		Properties properties = new Properties();
		properties.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");
		properties.put(Context.URL_PKG_PREFIXES,"org.jboss.naming:org.jnp.interfaces");
		properties.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");
		InitialContext iniCtx = new InitialContext(properties);

Object tmp = iniCtx.lookup("ConnectionFactory");
        QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;

que = (Queue) iniCtx.lookup("MyQueue");
		conn = qcf.createQueueConnection();
		session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
		conn.start();
	}

public static void stop() throws JMSException {
		conn.stop();
		session.close();
		conn.close();
	}

public static void sendCGRMessageToQueue(CGRMessage cgrMsgObj) throws JMSException {
		try {
		     setupConnection();
		} catch (JMSException e) {
			e.printStackTrace();
		} catch (NamingException e) {
			e.printStackTrace(); 
		}
		
		QueueSender send = session.createSender(que);
		ObjectMessage tm = session.createObjectMessage(cgrMsgObj);
		send.send(tm);
		send.close();
        SendJmsEvents.stop();
	}
	
	
}

ListenerTopic.java
This class actually listen to the Topic

public class ListenerTopic implements MessageListener {

String url_;
	String name_;
	TopicConnection conn = null;
	TopicSession session = null;
	Topic topic = null; 
	MessageConsumer recv = null;

public ListenerTopic(String url, String name) {
		super();
		url_ = url;
		name_ = name;
		
		initializeListener();
	}

public void onMessage(Message msg) {

TextMessage tm = (TextMessage) msg;

try {
			System.out.println("Incoming message: " + tm.getText());
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

public void initializeListener() {
		try {
			Properties props = new Properties();
			
			props.setProperty("java.naming.factory.initial","org.jnp.interfaces.NamingContextFactory");
			props.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");
			props.setProperty("java.naming.provider.url", url_);
			
			Context context = new InitialContext(props);
			TopicConnectionFactory tcf = (TopicConnectionFactory) context.lookup("ConnectionFactory");
			conn = tcf.createTopicConnection();
			topic = (Topic) context.lookup(name_);

session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
			conn.start();
			recv = session.createConsumer(topic);
		} catch (Exception e) {
			e.printStackTrace();
		} 
	}

public SDPMessage listeningSDPMessage() throws JMSException {
		ObjectMessage objmsg = null;
		SDPMessage sdpMsg =null;
		while (true) {
			Message m = recv.receive(1);
			if (m != null) {			
				if (m instanceof ObjectMessage) {
					objmsg = (ObjectMessage) m;					
					 sdpMsg = (SDPMessage) objmsg.getObject();					
					 break;
				} else {
					break;
				}
			}
		}
		recv.close();
		return sdpMsg;
	}
		
}