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