[rabbitmq-discuss] Dealing with Java JMS client

Tim Watson tim at rabbitmq.com
Mon Oct 15 11:46:13 BST 2012 

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.

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/e5f4b066/attachment.htm>

More information about the rabbitmq-discuss mailing list