qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sami Omer <so...@eoir.com>
Subject using Qpid JMS client with Rabbit-mq
Date Tue, 11 Feb 2014 19:35:15 GMT
Hello,

I was wondering if anyone has been successful at using the Qpid JMS client with Rabbit-mq.
I've been testing the qpid jms client (version 0.24) with a rabbitmq (version 3.2.2) and have
not been successful so far. My test producer seems to be able to create the JMS connection
and start it, create a Session, and the Queue, but It fails when I try to create a MessageProducer.
I've already tested the same test code on a QPid broker and it works as expected. Here's a
snippet and the stack I'm getting:

connection.start();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(subject);
MessageProducer producer = session.createProducer(queue);

java.lang.NullPointerException
        at org.apache.qpid.client.BasicMessageProducer_0_8.declareDestination(BasicMessageProducer_0_8.java:61)
        at org.apache.qpid.client.BasicMessageProducer.<init>(BasicMessageProducer.java:136)
        at org.apache.qpid.client.BasicMessageProducer.<init>(BasicMessageProducer.java:136)
        at org.apache.qpid.client.BasicMessageProducer_0_8.<init>(BasicMessageProducer_0_8.java:53)
        at org.apache.qpid.client.AMQSession_0_8.createMessageProducer(AMQSession_0_8.java:550)
        at org.apache.qpid.client.AMQSession_0_8.createMessageProducer(AMQSession_0_8.java:62)
        at org.apache.qpid.client.AMQSession$7.execute(AMQSession.java:2611)
        at org.apache.qpid.client.AMQSession$7.execute(AMQSession.java:2602)
        at org.apache.qpid.client.AMQConnectionDelegate_8_0.executeRetrySupport(AMQConnectionDelegate_8_0.java:333)
        at org.apache.qpid.client.AMQConnection.executeRetrySupport(AMQConnection.java:624)
        at org.apache.qpid.client.failover.FailoverRetrySupport.execute(FailoverRetrySupport.java:102)
        at org.apache.qpid.client.AMQSession.createProducerImpl(AMQSession.java:2600)
        at org.apache.qpid.client.AMQSession.createProducer(AMQSession.java:1176)
        at org.apache.qpid.client.AMQSession.createProducer(AMQSession.java:98)
        at example.Producer.produce(Producer.java:47)

Thanks,

Sami

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