Support other AMQP brokers

[jaxxstorm]

I'm trying to use graylog2 with ActiveMQ and the AMQP connector without much luck.

20:19:34.617 [main] WARN org.graylog2.radio.Radio - Could not connect to AMQP broker. Retrying in 5 seconds.
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:360) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533) ~[graylog2-radio.jar:na]
at org.graylog2.radio.Radio.getBroker(Radio.java:160) ~[graylog2-radio.jar:na]
at org.graylog2.radio.Radio.initialize(Radio.java:91) ~[graylog2-radio.jar:na]
at org.graylog2.radio.Main.main(Main.java:100) [graylog2-radio.jar:na]
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.io.EOFException
at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67) ~[graylog2-radio.jar:na]
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:313) ~[graylog2-radio.jar:na]
... 5 common frames omitted
java.io.EOFException: null
at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:273) ~[na:1.6.0_29]
at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:131) ~[graylog2-radio.jar:na]
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:515) ~[graylog2-radio.jar:na]

I'm guessing this is because it uses the rabbitmq library rather than an activemq library.

ActiveMQ is infinitely more highly available than RabbitMQ, so this would definitely be nice to have

[kroepke]

We will test this with other brokers to ensure compatibility.
Thank you for the report!

[brianredbeard]

speaking of AMQP libraries, have y'all seen Proton?

[lennartkoopmann]

Thanks @brianredbeard, we'll take a look at that! :)

[jaxxstorm]

Probably (hopefully!) a dupe #385