[rabbitmq-discuss] Can RabbitMQ AMQP client communicate with ActiveMQ AMQP transport?

[Troy Collinsworth]

Trying to write a single client that can communicate with local AMQP
servers and Windows Azure Service Bus.

The connection works fine to RabbitMQ server, but fails when connecting to
ActiveMQ server. Should this work?

ActiveMQ config: <transportConnector name="amqp" uri="amqp://0.0.0.0:5672...

ConnectionFactory factory = new ConnectionFactory();
factory.setUri("amqp://system/manager at localhost:5672");
Connection connection = factory.newConnection(); //throws the following
exception

Exception in thread "main" java.io.IOException
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:360)
at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516)
at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533)
at RabbitMQProducer.main(RabbitMQProducer.java:36)
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error;
reason: java.io.EOFException
at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
at
com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
at
com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:313)
... 3 more
Caused by: java.io.EOFException
at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:273)
at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95)
at
com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:131)
at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:515)

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130723/762aa39c/attachment.htm>

[Michael Klishin]

2013/7/23 Troy Collinsworth <troycollinsworth at gmail.com>

Post by Troy Collinsworth
The connection works fine to RabbitMQ server, but fails when connecting to
ActiveMQ server. Should this work?

No.

According to http://activemq.apache.org/amqp.html, ActiveMQ implements AMQP
1.0.

RabbitMQ Java client is an AMQP 0.9.1 client. There's an AMQP 1.0 RabbitMQ
plugin but clients use 0.9.1,
which is a different protocol from 1.0.