[graylog2] cannot start AMQP input

[Jiří Kolb]

Hi,
Trying to add AMQP input to connect with RabbitMQ, but input does not
start. Can you please help? Following is graylog server log:

2017-02-13_12:36:08.35670 2017-02-13 13:36:08,342 ERROR:
org.graylog2.shared.inputs.InputLauncher - The
[org.graylog2.inputs.gelf.amqp.GELFAMQPInput] input with ID
<58a1a833ea84240352ab0c9e> misfired. Reason: Connection refused.
2017-02-13_12:36:08.35733 org.graylog2.plugin.inputs.MisfireException:
org.graylog2.plugin.inputs.MisfireException: Could not launch AMQP consumer.
2017-02-13_12:36:08.36173 at
org.graylog2.plugin.inputs.MessageInput.launch(MessageInput.java:156)
~[graylog.jar:?]
2017-02-13_12:36:08.36503 at
org.graylog2.shared.inputs.InputLauncher$1.run(InputLauncher.java:84)
[graylog.jar:?]
2017-02-13_12:36:08.36512 at
com.codahale.metrics.InstrumentedExecutorService$InstrumentedRunnable.run(InstrumentedExecutorService.java:176)
[graylog.jar:?]
2017-02-13_12:36:08.36614 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_101]
2017-02-13_12:36:08.39847 at
java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_101]
2017-02-13_12:36:08.40479 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[?:1.8.0_101]
2017-02-13_12:36:08.40688 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[?:1.8.0_101]
2017-02-13_12:36:08.40894 at java.lang.Thread.run(Thread.java:745)
[?:1.8.0_101]
2017-02-13_12:36:08.41575 Caused by:
org.graylog2.plugin.inputs.MisfireException: Could not launch AMQP consumer.
2017-02-13_12:36:08.43687 at
org.graylog2.inputs.transports.AmqpTransport.doLaunch(AmqpTransport.java:179)
~[graylog.jar:?]
2017-02-13_12:36:08.43858 at
org.graylog2.plugin.inputs.transports.ThrottleableTransport.launch(ThrottleableTransport.java:75)
~[graylog.jar:?]
2017-02-13_12:36:08.44099 at
org.graylog2.plugin.inputs.MessageInput.launch(MessageInput.java:153)
~[graylog.jar:?]
2017-02-13_12:36:08.45928 ... 7 more
2017-02-13_12:36:08.46113 Caused by: java.net.ConnectException: Connection
refused
2017-02-13_12:36:08.46239 at java.net.PlainSocketImpl.socketConnect(Native
Method) ~[?:1.8.0_101]
2017-02-13_12:36:08.46372 at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
~[?:1.8.0_101]
2017-02-13_12:36:08.46735 at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
~[?:1.8.0_101]
2017-02-13_12:36:08.47077 at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
~[?:1.8.0_101]
2017-02-13_12:36:08.47511 at
java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[?:1.8.0_101]
2017-02-13_12:36:08.47630 at java.net.Socket.connect(Socket.java:589)
~[?:1.8.0_101]
2017-02-13_12:36:08.48921 at
com.rabbitmq.client.impl.FrameHandlerFactory.create(FrameHandlerFactory.java:47)
~[graylog.jar:?]
2017-02-13_12:36:08.52276 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:822)
~[graylog.jar:?]
2017-02-13_12:36:08.52512 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:778)
~[graylog.jar:?]
2017-02-13_12:36:08.53003 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:868)
~[graylog.jar:?]
2017-02-13_12:36:08.53488 at
org.graylog2.inputs.transports.AmqpConsumer.connect(AmqpConsumer.java:176)
~[graylog.jar:?]
2017-02-13_12:36:08.54119 at
org.graylog2.inputs.transports.AmqpConsumer.run(AmqpConsumer.java:108)
~[graylog.jar:?]
2017-02-13_12:36:08.55159 at
org.graylog2.inputs.transports.AmqpTransport.doLaunch(AmqpTransport.java:176)
~[graylog.jar:?]
2017-02-13_12:36:08.57116 at
org.graylog2.plugin.inputs.transports.ThrottleableTransport.launch(ThrottleableTransport.java:75)
~[graylog.jar:?]
2017-02-13_12:36:08.57121 at
org.graylog2.plugin.inputs.MessageInput.launch(MessageInput.java:153)
~[graylog.jar:?]
2017-02-13_12:36:08.57762 ... 7 more
2017-02-13_12:36:08.58163 2017-02-13 13:36:08,361 INFO :
org.graylog2.inputs.InputStateListener - Input [GELF
AMQP/58a1a833ea84240352ab0c9e] is now TERMINATED
2017-02-13_12:36:08.58165 2017-02-13 13:36:08,345 ERROR:
com.google.common.eventbus.EventBus.graylog-eventbus - Exception thrown by
subscriber method
inputStateChanged(org.graylog2.plugin.events.inputs.IOStateChangedEvent) on
subscriber ***@47629063 when dispatching
event: IOStateChangedEvent{oldState=STARTING, newState=FAILED,
changedState=InputState{stoppable=GELFAMQPInput{title=rabbitmq,
type=org.graylog2.inputs.gelf.amqp.GELFAMQPInput, nodeId=null},
state=FAILED, startedAt=2017-02-13T12:36:08.321Z, detailedMessage='null'}}
2017-02-13_12:36:08.59262 java.lang.NullPointerException
2017-02-13_12:36:08.59516 at
java.util.Objects.requireNonNull(Objects.java:203) ~[?:1.8.0_101]
2017-02-13_12:36:08.59523 at
org.graylog2.shared.system.activities.Activity.<init>(Activity.java:34)
~[graylog.jar:?]
2017-02-13_12:36:08.62209 at
org.graylog2.inputs.InputStateListener.inputStateChanged(InputStateListener.java:57)
~[graylog.jar:?]
2017-02-13_12:36:08.62213 at
sun.reflect.GeneratedMethodAccessor120.invoke(Unknown Source) ~[?:?]
2017-02-13_12:36:08.62214 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_101]
2017-02-13_12:36:08.62215 at
java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_101]
2017-02-13_12:36:08.62215 at
com.google.common.eventbus.Subscriber.invokeSubscriberMethod(Subscriber.java:95)
~[graylog.jar:?]
2017-02-13_12:36:08.62464 at
com.google.common.eventbus.Subscriber$SynchronizedSubscriber.invokeSubscriberMethod(Subscriber.java:154)
~[graylog.jar:?]
2017-02-13_12:36:08.62862 at
com.google.common.eventbus.Subscriber$1.run(Subscriber.java:80)
[graylog.jar:?]
2017-02-13_12:36:08.63280 at
com.codahale.metrics.InstrumentedExecutorService$InstrumentedRunnable.run(InstrumentedExecutorService.java:176)
[graylog.jar:?]
2017-02-13_12:36:08.63287 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[?:1.8.0_101]
2017-02-13_12:36:08.63288 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[?:1.8.0_101]
2017-02-13_12:36:08.63700 at java.lang.Thread.run(Thread.java:745)
[?:1.8.0_101]


Thank you,
Jiri

[Jan Doberstein]

Hej Jiri,

according to your provided logfile something is wrong with your
configuration. You should check all settings and if Graylog is able to
connect to the AMQP Server on the configured Port.

regards
Jan

Post by Jiří Kolb
Hi,
Trying to add AMQP input to connect with RabbitMQ, but input does not
org.graylog2.shared.inputs.InputLauncher - The
[org.graylog2.inputs.gelf.amqp.GELFAMQPInput] input with ID
<58a1a833ea84240352ab0c9e> misfired. Reason: Connection refused.
org.graylog2.plugin.inputs.MisfireException: Could not launch AMQP consumer.
2017-02-13_12:36:08.36173 at
org.graylog2.plugin.inputs.MessageInput.launch(MessageInput.java:156)
~[graylog.jar:?]
2017-02-13_12:36:08.36503 at
org.graylog2.shared.inputs.InputLauncher$1.run(InputLauncher.java:84)
[graylog.jar:?]
2017-02-13_12:36:08.36512 at
com.codahale.metrics.InstrumentedExecutorService$InstrumentedRunnable.run(InstrumentedExecutorService.java:176)
[graylog.jar:?]
2017-02-13_12:36:08.36614 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_101]
2017-02-13_12:36:08.39847 at
java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_101]
2017-02-13_12:36:08.40479 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[?:1.8.0_101]
2017-02-13_12:36:08.40688 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[?:1.8.0_101]
2017-02-13_12:36:08.40894 at java.lang.Thread.run(Thread.java:745)
[?:1.8.0_101]
org.graylog2.plugin.inputs.MisfireException: Could not launch AMQP consumer.
2017-02-13_12:36:08.43687 at
org.graylog2.inputs.transports.AmqpTransport.doLaunch(AmqpTransport.java:179)
~[graylog.jar:?]
2017-02-13_12:36:08.43858 at
org.graylog2.plugin.inputs.transports.ThrottleableTransport.launch(ThrottleableTransport.java:75)
~[graylog.jar:?]
2017-02-13_12:36:08.44099 at
org.graylog2.plugin.inputs.MessageInput.launch(MessageInput.java:153)
~[graylog.jar:?]
2017-02-13_12:36:08.45928 ... 7 more
2017-02-13_12:36:08.46113 Caused by: java.net.ConnectException: Connection
refused
2017-02-13_12:36:08.46239 at
java.net.PlainSocketImpl.socketConnect(Native Method) ~[?:1.8.0_101]
2017-02-13_12:36:08.46372 at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
~[?:1.8.0_101]
2017-02-13_12:36:08.46735 at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
~[?:1.8.0_101]
2017-02-13_12:36:08.47077 at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
~[?:1.8.0_101]
2017-02-13_12:36:08.47511 at
java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[?:1.8.0_101]
2017-02-13_12:36:08.47630 at java.net.Socket.connect(Socket.java:589)
~[?:1.8.0_101]
2017-02-13_12:36:08.48921 at
com.rabbitmq.client.impl.FrameHandlerFactory.create(FrameHandlerFactory.java:47)
~[graylog.jar:?]
2017-02-13_12:36:08.52276 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:822)
~[graylog.jar:?]
2017-02-13_12:36:08.52512 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:778)
~[graylog.jar:?]
2017-02-13_12:36:08.53003 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:868)
~[graylog.jar:?]
2017-02-13_12:36:08.53488 at
org.graylog2.inputs.transports.AmqpConsumer.connect(AmqpConsumer.java:176)
~[graylog.jar:?]
2017-02-13_12:36:08.54119 at
org.graylog2.inputs.transports.AmqpConsumer.run(AmqpConsumer.java:108)
~[graylog.jar:?]
2017-02-13_12:36:08.55159 at
org.graylog2.inputs.transports.AmqpTransport.doLaunch(AmqpTransport.java:176)
~[graylog.jar:?]
2017-02-13_12:36:08.57116 at
org.graylog2.plugin.inputs.transports.ThrottleableTransport.launch(ThrottleableTransport.java:75)
~[graylog.jar:?]
2017-02-13_12:36:08.57121 at
org.graylog2.plugin.inputs.MessageInput.launch(MessageInput.java:153)
~[graylog.jar:?]
2017-02-13_12:36:08.57762 ... 7 more
org.graylog2.inputs.InputStateListener - Input [GELF
AMQP/58a1a833ea84240352ab0c9e] is now TERMINATED
com.google.common.eventbus.EventBus.graylog-eventbus - Exception thrown by
subscriber method
inputStateChanged(org.graylog2.plugin.events.inputs.IOStateChangedEvent) on
event: IOStateChangedEvent{oldState=STARTING, newState=FAILED,
changedState=InputState{stoppable=GELFAMQPInput{title=rabbitmq,
type=org.graylog2.inputs.gelf.amqp.GELFAMQPInput, nodeId=null},
state=FAILED, startedAt=2017-02-13T12:36:08.321Z, detailedMessage='null'}}
2017-02-13_12:36:08.59262 java.lang.NullPointerException
2017-02-13_12:36:08.59516 at
java.util.Objects.requireNonNull(Objects.java:203) ~[?:1.8.0_101]
2017-02-13_12:36:08.59523 at
org.graylog2.shared.system.activities.Activity.<init>(Activity.java:34)
~[graylog.jar:?]
2017-02-13_12:36:08.62209 at
org.graylog2.inputs.InputStateListener.inputStateChanged(InputStateListener.java:57)
~[graylog.jar:?]
2017-02-13_12:36:08.62213 at
sun.reflect.GeneratedMethodAccessor120.invoke(Unknown Source) ~[?:?]
2017-02-13_12:36:08.62214 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_101]
2017-02-13_12:36:08.62215 at
java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_101]
2017-02-13_12:36:08.62215 at
com.google.common.eventbus.Subscriber.invokeSubscriberMethod(Subscriber.java:95)
~[graylog.jar:?]
2017-02-13_12:36:08.62464 at
com.google.common.eventbus.Subscriber$SynchronizedSubscriber.invokeSubscriberMethod(Subscriber.java:154)
~[graylog.jar:?]
2017-02-13_12:36:08.62862 at
com.google.common.eventbus.Subscriber$1.run(Subscriber.java:80)
[graylog.jar:?]
2017-02-13_12:36:08.63280 at
com.codahale.metrics.InstrumentedExecutorService$InstrumentedRunnable.run(InstrumentedExecutorService.java:176)
[graylog.jar:?]
2017-02-13_12:36:08.63287 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[?:1.8.0_101]
2017-02-13_12:36:08.63288 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[?:1.8.0_101]
2017-02-13_12:36:08.63700 at java.lang.Thread.run(Thread.java:745)
[?:1.8.0_101]
Thank you,
Jiri