QPID Broker not getting messages when used
((XAQueueSession)session1).getQueueSession().createSender(null) for XA from
QPID Client
----------------------------------------------------------------------------------------------------------------------------------
Key: QPID-2729
URL: https://issues.apache.org/jira/browse/QPID-2729
Project: Qpid
Issue Type: Bug
Components: Java Broker, Java Broker MessageStore - DerbyStore, Java
Client, Java Common
Affects Versions: 0.6
Environment: Windows/Linux
Reporter: Yogesh
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.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
