qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yogesh pathade <yogesh_path...@yahoo.co.uk>
Subject QPID Broker not getting messages when used ((XAQueueSession)session1).getQueueSession().createSender(null) for XA from QPID Client
Date Mon, 12 Jul 2010 09:51:50 GMT
Hi,





I am trying to send Message to queue using QPID Java Broker 0.6.





I am seeing weired behavior when I use the JMS Queue sender for XA 
connection, the sender completes its operation successfully but the JMS 
QPID Broker doesn't receive anything.





When used with the normal Sender created as follows it works fine





                Session session1 = 
((XAQueueConnection)xaConn1).createXAQueueSession();


                javax.jms.Queue queue = session1.createQueue(queueName);


                javax.jms.TextMessage message1 = 
session1.createTextMessage(textMessage);


                MessageProducer XAsender = 
session1.createProducer(null);


                ((QueueSender) XAsender).send(queue, message1);





However if you create a Sender by using 
Session.getQueueSession().createSender(null) then the message is not 
sent to the QPID Broker (code snippet given below)





                Session session1 = 
((XAQueueConnection)xaConn1).createXAQueueSession();


                javax.jms.Queue queue = session1.createQueue(queueName);


                javax.jms.TextMessage message1 = 
session1.createTextMessage(textMessage);


                MessageProducer XAsender1 = 
((XAQueueSession)session1).getQueueSession().createSender(null);


                ((MessageProducer) XAsender1).send(queue, message1);








Use normal connection code for this example.





Let me know if you need more details regarding this issue.

Let me know if I am missing something over here.

Thanks,
Yogesh



      
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message