[rabbitmq-discuss] Dealing with Java JMS client

Tim Watson tim at rabbitmq.com
Mon Oct 15 11:51:48 BST 2012 

On 10/15/2012 11:46 AM, Tim Watson wrote:
> Hi,
>
> RabbitMQ is an implementation of AMQP and does not currently support 
> JMS, so this will not work. You will need to the the official RabbitMQ 
> java client directly in order to access RabbitMQ.
>

Sorry, I should probably clarify here. A JMS client that claims to 
support AMQP-0.9.1 *might* work with RabbitMQ, but at also may not and 
you would need to contact the JMS component author/vendor if you are 
running into problems with it. For details of RabbitMQ's conformance to 
the AMQP 0.9.1 specification, see 
http://www.rabbitmq.com/specification.html for more details.

Cheers,

Tim

> Cheers,
> Tim
>
> On 10/15/2012 11:03 AM, vedanth wrote:
>> Hi Everyone, Am trying to use openamq java jms client with rabbit 
>> mq(Version rabbitmq-server-2.8.7-.noarch.rpm). I have downloaded the 
>> openamq jms client from *https://github.com/imatix/openamq-jms* which 
>> currently implements 0.9 amqp spec. When i execute the sample program 
>> as suggested in *readme.txt* i get an exception which says 
>> "Unsupported field table type". Detailed stacktrace bin]# 
>> ./serviceProvidingClient.sh 192.168.2.41:5672 guest guest / main 
>> 2012-10-15 14:53:18,260 INFO 
>> [org.openamq.requestreply1.ServiceProvidingClient] Starting... 106 
>> [main] INFO org.openamq.client.transport.SocketTransportConnection - 
>> Attempting connection to apache.treetechnologies.net:5672 324 
>> [AnonymousIoService-1-1] INFO 
>> org.openamq.client.protocol.AMQProtocolHandler - Exception caught 
>> therefore going to attempt failover: 
>> org.apache.mina.filter.codec.ProtocolDecoderException: 
>> org.openamq.framing.AMQFrameDecodingException: Unsupported field 
>> table type: F (70), length=290, sizeRead=0, sizeRemaining=318 
>> (Hexdump: 00 00 00 58 12 70 75 62 6C 69 73 68 65 72 5F 63 6F 6E 66 69 
>> 72 6D 73 74 01 1A 65 78 63 68 61 6E 67 65 5F 65 78 63 68 61 6E 67 65 
>> 5F 62 69 6E 64 69 6E 67 73 74 01 0A 62 61 73 69 63 2E 6E 61 63 6B 74 
>> 01 16 63 6F 6E 73 75 6D 65 72 5F 63 61 6E 63 65 6C 5F 6E 6F 74 69 66 
>> 79 74 01 09 63 6F 70 79 72 69 67 68 74 53 00 00 00 24 43 6F 70 79 72 
>> 69 67 68 74 20 28 43 29 20 32 30 30 37 2D 32 30 31 32 20 56 4D 77 61 
>> 72 65 2C 20 49 6E 63 2E 0B 69 6E 66 6F 72 6D 61 74 69 6F 6E 53 00 00 
>> 00 35 4C 69 63 65 6E 73 65 64 20 75 6E 64 65 72 20 74 68 65 20 4D 50 
>> 4C 2E 20 20 53 65 65 20 68 74 74 70 3A 2F 2F 77 77 77 2E 72 61 62 62 
>> 69 74 6D 71 2E 63 6F 6D 2F 08 70 6C 61 74 66 6F 72 6D 53 00 00 00 0A 
>> 45 72 6C 61 6E 67 2F 4F 54 50 07 70 72 6F 64 75 63 74 53 00 00 00 08 
>> 52 61 62 62 69 74 4D 51 07 76 65 72 73 69 6F 6E 53 00 00 00 05 32 2E 
>> 38 2E 37 00 00 00 0E 50 4C 41 49 4E 20 41 4D 51 50 4C 41 49 4E 00 00 
>> 00 05 65 6E 5F 55 53 CE) 
>> org.apache.mina.filter.codec.ProtocolDecoderException: 
>> org.openamq.framing.AMQFrameDecodingException: Unsupported field 
>> table type: F (70), length=290, sizeRead=0, sizeRemaining=318 
>> (Hexdump: 00 00 00 58 12 70 75 62 6C 69 73 68 65 72 5F 63 6F 6E 66 69 
>> 72 6D 73 74 01 1A 65 78 63 68 61 6E 67 65 5F 65 78 63 68 61 6E 67 65 
>> 5F 62 69 6E 64 69 6E 67 73 74 01 0A 62 61 73 69 63 2E 6E 61 63 6B 74 
>> 01 16 63 6F 6E 73 75 6D 65 72 5F 63 61 6E 63 65 6C 5F 6E 6F 74 69 66 
>> 79 74 01 09 63 6F 70 79 72 69 67 68 74 53 00 00 00 24 43 6F 70 79 72 
>> 69 67 68 74 20 28 43 29 20 32 30 30 37 2D 32 30 31 32 20 56 4D 77 61 
>> 72 65 2C 20 49 6E 63 2E 0B 69 6E 66 6F 72 6D 61 74 69 6F 6E 53 00 00 
>> 00 35 4C 69 63 65 6E 73 65 64 20 75 6E 64 65 72 20 74 68 65 20 4D 50 
>> 4C 2E 20 20 53 65 65 20 68 74 74 70 3A 2F 2F 77 77 77 2E 72 61 62 62 
>> 69 74 6D 71 2E 63 6F 6D 2F 08 70 6C 61 74 66 6F 72 6D 53 00 00 00 0A 
>> 45 72 6C 61 6E 67 2F 4F 54 50 07 70 72 6F 64 75 63 74 53 00 00 00 08 
>> 52 61 62 62 69 74 4D 51 07 76 65 72 73 69 6F 6E 53 00 00 00 05 32 2E 
>> 38 2E 37 00 00 00 0E 50 4C 41 49 4E 20 41 4D 51 50 4C 41 49 4E 00 00 
>> 00 05 65 6E 5F 55 53 CE) at 
>> org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:169) 
>> at 
>> org.apache.mina.common.support.AbstractIoFilterChain.callNextMessageReceived(AbstractIoFilterChain.java:501) 
>> at 
>> org.apache.mina.common.support.AbstractIoFilterChain.access$1000(AbstractIoFilterChain.java:51) 
>> at 
>> org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.messageReceived(AbstractIoFilterChain.java:788) 
>> at 
>> org.apache.mina.filter.ThreadPoolFilter.processEvent(ThreadPoolFilter.java:718) 
>> at 
>> org.apache.mina.filter.ThreadPoolFilter$Worker.processEvents(ThreadPoolFilter.java:474) 
>> at 
>> org.apache.mina.filter.ThreadPoolFilter$Worker.run(ThreadPoolFilter.java:429) 
>> Caused by: org.openamq.framing.AMQFrameDecodingException: Unsupported 
>> field table type: F (70), length=290, sizeRead=0, sizeRemaining=318 
>> at org.openamq.framing.FieldTable.(FieldTable.java:65) at 
>> org.openamq.framing.EncodingUtils.readFieldTable(EncodingUtils.java:264) 
>> at 
>> org.openamq.framing.ConnectionStartBody.populateMethodBodyFromBuffer(ConnectionStartBody.java:58) 
>> at 
>> org.openamq.framing.AMQMethodBody.populateFromBuffer(AMQMethodBody.java:46) 
>> at org.openamq.framing.AMQFrame.populateFromBuffer(AMQFrame.java:49) 
>> at 
>> org.openamq.framing.AMQDataBlockDecoder.createAndPopulateFrame(AMQDataBlockDecoder.java:82) 
>> at 
>> org.openamq.framing.AMQDataBlockDecoder.decode(AMQDataBlockDecoder.java:95) 
>> at org.openamq.codec.AMQDecoder.doDecodeDataBlock(AMQDecoder.java:54) 
>> at org.openamq.codec.AMQDecoder.doDecode(AMQDecoder.java:37) at 
>> org.apache.mina.filter.codec.CumulativeProtocolDecoder.decode(CumulativeProtocolDecoder.java:97) 
>> at 
>> org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:158) 
>> ... 6 more 334 [AnonymousIoService-1-1] INFO 
>> org.openamq.client.protocol.AMQProtocolHandler - Session closed 
>> called with failover state currently FailoverState: NOT STARTED 334 
>> [AnonymousIoService-1-1] INFO 
>> org.openamq.client.protocol.AMQProtocolHandler - Protocol Session 
>> [org.openamq.client.protocol.AMQProtocolHandler at 69945ce] closed 341 
>> [main] INFO org.openamq.client.AMQConnection - Unable to connect to 
>> broker at 192.168.2.41:5672 org.openamq.AMQException: Error: 
>> org.openamq.client.protocol.FailoverException: Failing over about to 
>> start at 
>> org.openamq.client.state.StateWaiter.waituntilStateHasChanged(StateWaiter.java:59) 
>> at 
>> org.openamq.client.state.AMQStateManager.attainState(AMQStateManager.java:204) 
>> at 
>> org.openamq.client.protocol.AMQProtocolHandler.attainState(AMQProtocolHandler.java:392) 
>> at 
>> org.openamq.client.AMQConnection.makeBrokerConnection(AMQConnection.java:247) 
>> at org.openamq.client.AMQConnection.(AMQConnection.java:181) at 
>> org.openamq.client.AMQConnection.(AMQConnection.java:154) at 
>> org.openamq.requestreply1.ServiceProvidingClient.(ServiceProvidingClient.java:28) 
>> at 
>> org.openamq.requestreply1.ServiceProvidingClient.main(ServiceProvidingClient.java:152) 
>> Caused by: org.openamq.client.protocol.FailoverException: Failing 
>> over about to start at 
>> org.openamq.client.protocol.AMQProtocolHandler$FailoverHandler.run(AMQProtocolHandler.java:93) 
>> at java.lang.Thread.run(Thread.java:679) 345 [Thread-2] INFO 
>> org.openamq.client.protocol.AMQProtocolHandler - Starting failover 
>> process main 2012-10-15 14:53:18,650 ERROR 
>> [org.openamq.requestreply1.ServiceProvidingClient] Error: 
>> org.openamq.AMQException: Unable to connect to any specified broker 
>> in list 192.168.2.41:5672 org.openamq.AMQException: Unable to connect 
>> to any specified broker in list 192.168.2.41:5672 at 
>> org.openamq.client.AMQConnection.(AMQConnection.java:198) at 
>> org.openamq.client.AMQConnection.(AMQConnection.java:154) at 
>> org.openamq.requestreply1.ServiceProvidingClient.(ServiceProvidingClient.java:28) 
>> at 
>> org.openamq.requestreply1.ServiceProvidingClient.main(ServiceProvidingClient.java:152) 
>> 10119 [AnonymousIoService-1-2] INFO 
>> org.openamq.client.protocol.AMQProtocolHandler - Session closed 
>> called with failover state currently FailoverState: IN PROGRESS 10119 
>> [AnonymousIoService-1-2] INFO 
>> org.openamq.client.protocol.AMQProtocolHandler - Protocol Session 
>> [org.openamq.client.protocol.AMQProtocolHandler at 69945ce] closed 
>> [root at apache bin]# Any help on using java jms client with 
>> rabbitmq-server-2.8.7 would be of great help
>> ------------------------------------------------------------------------
>> View this message in context: Dealing with Java JMS client 
>> <http://rabbitmq.1065348.n5.nabble.com/Dealing-with-Java-JMS-client-tp22559.html>
>> Sent from the RabbitMQ mailing list archive 
>> <http://rabbitmq.1065348.n5.nabble.com/> at Nabble.com.
>>
>>
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20121015/84c47bdd/attachment.htm>

More information about the rabbitmq-discuss mailing list