[
https://issues.apache.org/jira/browse/QPID-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robbie Gemmell resolved QPID-2729.
----------------------------------
Resolution: Invalid
The Java broker doesnt support XA yet, which is the likely cause of the issue.
I am closing this JIRA out, but linking it to QPID-24 which is the JIRA for
doing XA for the Java broker.
> 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 Derby Store, 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.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]