Skip to content
This repository was archived by the owner on Jun 2, 2025. It is now read-only.
This repository was archived by the owner on Jun 2, 2025. It is now read-only.

When AMQP broker restarts, logs are flooded with stacktraces #12

@daviddawson

Description

@daviddawson

Broker goes offline, this error repeatedly appears until the broker is available again

com.rabbitmq.client.ShutdownSignalException: connection error
	at com.rabbitmq.client.QueueingConsumer.handle(QueueingConsumer.java:206) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.QueueingConsumer.nextDelivery(QueueingConsumer.java:223) ~[amqp-client-4.1.1.jar:4.1.1]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09BroadcastListener.lambda$run$1(RabbitMq09BroadcastListener.java:66) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09ClientAmqpConnection.addToExecList(RabbitMq09ClientAmqpConnection.java:69) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09ClientAmqpConnection.access$000(RabbitMq09ClientAmqpConnection.java:23) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09ClientAmqpConnection$1.executeOnEveryConnect(RabbitMq09ClientAmqpConnection.java:78) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09BroadcastListener.run(RabbitMq09BroadcastListener.java:48) ~[muon-amqp-0.0.7.jar:na]
	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_131]
Caused by: java.io.EOFException: null
	at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:290) ~[na:1.8.0_131]
	at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:91) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:164) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:578) ~[amqp-client-4.1.1.jar:4.1.1]
	... 1 common frames omitted

Then, photon reconnects, but this stack still appears. Photon is fully functional at this point.

2017-07-18 14:10:32.649 DEBUG 19614 --- [       Thread-3] i.m.e.a.r.RabbitMq09BroadcastListener    : Channel shuts down

com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; cause: java.io.EOFException
	at com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:209) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:352) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:346) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.impl.ChannelN.basicAck(ChannelN.java:1169) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.impl.recovery.RecoveryAwareChannelN.basicAck(RecoveryAwareChannelN.java:89) ~[amqp-client-4.1.1.jar:4.1.1]
	at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicAck(AutorecoveringChannel.java:436) ~[amqp-client-4.1.1.jar:4.1.1]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09BroadcastListener.lambda$run$1(RabbitMq09BroadcastListener.java:82) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09ClientAmqpConnection.addToExecList(RabbitMq09ClientAmqpConnection.java:69) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09ClientAmqpConnection.access$000(RabbitMq09ClientAmqpConnection.java:23) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09ClientAmqpConnection$1.executeOnEveryConnect(RabbitMq09ClientAmqpConnection.java:78) ~[muon-amqp-0.0.7.jar:na]
	at io.muoncore.extension.amqp.rabbitmq09.RabbitMq09BroadcastListener.run(RabbitMq09BroadcastListener.java:48) ~[muon-amqp-0.0.7.jar:na]
	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_131]

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions