You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by Josh Carlson <jo...@kaazing.com> on 2014/07/24 19:42:05 UTC
How do I run the AMQP 1.0 JMS client example?
Hi All,
I'm struggling trying to get the AMQP 1.0 JMS client to work. I built it
manually because it wouldn't build even after specifying a classpath for
ant it still couldn't find the JMS librarys. The exception I currently
get is below. Any help would be appreciated.
[jcarlson@Rocky java]$ java -cp
/home/jcarlson/Downloads/qpid-java-amqp-1-0-client-jms-0.28/lib/qpid-all.jar:.
org.apache.qpid.amqp_1_0.jms.example.Hello
Caught exception: null
javax.jms.JMSException
at
org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.createClientReceiver(MessageConsumerImpl.java:176)
at
org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:127)
at
org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:87)
at
org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createConsumer(SessionImpl.java:435)
at
org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createConsumer(SessionImpl.java:406)
at
org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createConsumer(SessionImpl.java:59)
at org.apache.qpid.amqp_1_0.jms.example.Hello.main(Hello.java:62)
Thanks
Josh
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: How do I run the AMQP 1.0 JMS client example?
Posted by Josh Carlson <jo...@kaazing.com>.
> What broker are you using? You need to create a queue called 'queue'.
> It's failing because no such queue exists.
>
QPID - java. That worked. Thanks Gordon!
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: How do I run the AMQP 1.0 JMS client example?
Posted by Gordon Sim <gs...@redhat.com>.
On 07/24/2014 06:59 PM, Josh Carlson wrote:
> Here is what I see in the client log:
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
> SaslMechanisms{saslServerMechanisms=[AMQPLAIN, PLAIN, CRAM-MD5]}
> [Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|0] :
> SaslInit{mechanism=PLAIN,initialResponse=\x00guest\x00guest,hostname=default}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
> SaslOutcome{code=ok}
> [Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|0] :
> Open{containerId=test-client,hostname=default,maxFrameSize=65536,channelMax=255}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|0] :
> Begin{nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048,handleMax=4294967295}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|1] :
> Begin{nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048,handleMax=4294967295}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|1] :
> Attach{name=queue->
> (e60eb4ab-346b-47e7-9240-253f080b5da3),handle=0,role=receiver,sndSettleMode=unsettled,rcvSettleMode=first,source=Source{address=queue,durable=none,expiryPolicy=link-detach,filter={jms-selector=JMSSelector{hello='true'}}},target=Target{address=eee71b07-6f1f-43ca-b826-23ce39b75b47}}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
> Open{containerId=147ed3a6-ebd6-4c03-9f9d-0b0e45bc0dde,maxFrameSize=32768,channelMax=255,properties={qpid.instance_name=Broker,
> product=qpid, qpid.build=1594179, version=0.28}}
> [Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
> Begin{remoteChannel=0,nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|1] :
> Begin{remoteChannel=1,nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|1] :
> Attach{name=queue->
> (e60eb4ab-346b-47e7-9240-253f080b5da3),handle=0,role=sender,sndSettleMode=unsettled,rcvSettleMode=first,target=Target{address=eee71b07-6f1f-43ca-b826-23ce39b75b47},initialDeliveryCount=0}
>
> [Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|1] :
> Detach{handle=0,error=Error{condition=not-found}}
> [Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|1] :
> Detach{handle=0}
What broker are you using? You need to create a queue called 'queue'.
It's failing because no such queue exists.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: How do I run the AMQP 1.0 JMS client example?
Posted by Josh Carlson <jo...@kaazing.com>.
Here is what I see in the client log:
[Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
SaslMechanisms{saslServerMechanisms=[AMQPLAIN, PLAIN, CRAM-MD5]}
[Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|0] :
SaslInit{mechanism=PLAIN,initialResponse=\x00guest\x00guest,hostname=default}
[Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
SaslOutcome{code=ok}
[Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|0] :
Open{containerId=test-client,hostname=default,maxFrameSize=65536,channelMax=255}
[Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|0] :
Begin{nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048,handleMax=4294967295}
[Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|1] :
Begin{nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048,handleMax=4294967295}
[Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|1] :
Attach{name=queue->
(e60eb4ab-346b-47e7-9240-253f080b5da3),handle=0,role=receiver,sndSettleMode=unsettled,rcvSettleMode=first,source=Source{address=queue,durable=none,expiryPolicy=link-detach,filter={jms-selector=JMSSelector{hello='true'}}},target=Target{address=eee71b07-6f1f-43ca-b826-23ce39b75b47}}
[Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
Open{containerId=147ed3a6-ebd6-4c03-9f9d-0b0e45bc0dde,maxFrameSize=32768,channelMax=255,properties={qpid.instance_name=Broker,
product=qpid, qpid.build=1594179, version=0.28}}
[Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|0] :
Begin{remoteChannel=0,nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048}
[Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|1] :
Begin{remoteChannel=1,nextOutgoingId=0,incomingWindow=2048,outgoingWindow=2048}
[Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|1] :
Attach{name=queue->
(e60eb4ab-346b-47e7-9240-253f080b5da3),handle=0,role=sender,sndSettleMode=unsettled,rcvSettleMode=first,target=Target{address=eee71b07-6f1f-43ca-b826-23ce39b75b47},initialDeliveryCount=0}
[Thu Jul 24 13:48:12 EDT 2014] FINE: RECV[localhost/127.0.0.1:5672|1] :
Detach{handle=0,error=Error{condition=not-found}}
[Thu Jul 24 13:48:12 EDT 2014] FINE: SEND[localhost/127.0.0.1:5672|1] :
Detach{handle=0}
Thanks
-Josh
On 07/24/2014 01:42 PM, Josh Carlson wrote:
> Hi All,
>
> I'm struggling trying to get the AMQP 1.0 JMS client to work. I built
> it manually because it wouldn't build even after specifying a
> classpath for ant it still couldn't find the JMS librarys. The
> exception I currently get is below. Any help would be appreciated.
>
> [jcarlson@Rocky java]$ java -cp
> /home/jcarlson/Downloads/qpid-java-amqp-1-0-client-jms-0.28/lib/qpid-all.jar:.
> org.apache.qpid.amqp_1_0.jms.example.Hello
> Caught exception: null
> javax.jms.JMSException
> at
> org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.createClientReceiver(MessageConsumerImpl.java:176)
> at
> org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:127)
> at
> org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:87)
> at
> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createConsumer(SessionImpl.java:435)
> at
> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createConsumer(SessionImpl.java:406)
> at
> org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createConsumer(SessionImpl.java:59)
> at org.apache.qpid.amqp_1_0.jms.example.Hello.main(Hello.java:62)
>
> Thanks
>
> Josh
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org