[ 
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]

Reply via email to