JBoss JMS Queue Message not reached to configured queue, but its wrongly redirected to default DLQ.

[Mehul Kaps Kapadia]

Hi All,

I have created my own Jboss[5.1.0 GA] JMS Queue, as per following configuration in <JBOSS_HOME>/server/default/deploy/SIClusterQueue-service.xml

<server>
<mbean code="org.jboss.jms.server.destination.QueueService"
name="jboss.messaging.destination:service=Queue,name=SIClusterQueue"
xmbean-dd="xmdesc/Queue-xmbean.xml">
<depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>
<depends>jboss.messaging:service=PostOffice</depends>
</mbean>
</server>

also there are 2 other queue that JBoss provides by default : DLQ and ExpireyQueue.

When I push one message to my own configured queue[SIClusterQueue] and is of the type javax.jms.Message, My Receiver is able to receive that message and everything is fine.

But now the problem is, when my sender puts the customized message object to queue[SIClusterQueue], i.e not of the type javax.jms.Message, but my own object - which implements serializable interface. following occurs.

Sender is able to send message to Queue, this time message is not visible under my configured queue[SIClusterQueue], instead its available under JBOSS default DLQ [as shown in attached screenshot from JBOSS Admin Page].

I can confirm that both my sender and receiver are referring to my configured queue [SIClusterQueue], not to the default DLQ. and there is no Exception while sending/receiving the Message in any case.

My onMessage Method logic in receiver is as follow. where MessgeEvent Object is my own customized object.

@Override
	public void onMessage(Message message) {
	       try {
	    	                 ObjectMessage objInMsg  = (ObjectMessage)message;
		  		 MessageEvent event = (MessageEvent)objInMsg.getObject();
	       } 
               catch (JMSException ex) 
               {
	               ex.printStackTrace();
	       }
	}

Following is the sender code which shows how it packed my customizedObject[MessageEvent].

props = new Properties();
props.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory" );
props.setProperty(Context.PROVIDER_URL, "172.19.102.206:1099");  


InitialContext ctx = new InitialContext(props);
QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.lookup("/ConnectionFactory");
Queue queue = (Queue) ctx.lookup("/queue/SIClusterQueue");
QueueConnection queueConn = connFactory.createQueueConnection();
QueueSession queueSession = queueConn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
QueueSender queueSender = queueSession.createSender(queue);
queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

ObjectMessage objOutMsg = queueSession.createObjectMessage();
objOutMsg.setObject(new MessageEvent("SAI13", 1 , new Object()));

queueSender.send(objOutMsg);
			                                                                      
queueConn.close();

can someone please help here and share your expertise.

Why my JMS Queue messege is redirected to default DLQ, it should redirect to my own configured Queue to which my consumers are listen to.

Regards,
Mehul Kapadia

[Mehul Kaps Kapadia]

Hi All,

I got the solution, so thought to share with you all.

In first try I have created the JMS Queue from backend, means - I directly kept the MyQueue-service.xml file in <JBOSS_HOME>/server/default/deploy/ directory. in which queue xml config doesn't have the JNDI config.

then I tried creating from the JBOSS Admin Console in following way, and it worked perferctly fine.

JMS Destination > Queue > Add new Resource

provide required details and your queue is ready to go.


Queue Service XML file:
---------------------------

<?xml version="1.0" encoding="UTF-8" standalone="yes"?> <server> <mbean xmbean-dd="xmdesc/Queue-xmbean.xml" name="jboss.messaging.destination:service=Queue,name=BCQueue" code="org.jboss.jms.server.destination.QueueService"> <attribute name="JNDIName">/queue/BCQueue</attribute> <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends> <depends>jboss.messaging:service=PostOffice</depends> </mbean> </server>


Regards,
Mehul Kapadia