qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robbie Gemmell <robbie.gemm...@gmail.com>
Subject Re: using Qpid JMS client with Rabbit-mq
Date Tue, 11 Feb 2014 21:12:56 GMT
Please see https://issues.apache.org/jira/browse/QPID-5526 for a pre-baked
discussion on this, noting that the mentioned RC4 has passed its vote and
is thus now 0.26, which will be distributed officially in the days ahead
(we are in the middle of some infrastructure changes that are delaying the
publication slightly)

Robbie

On 11 February 2014 19:35, Sami Omer <somer@eoir.com> wrote:

> 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