SimpleMessageListenerContainer — исключение, вызванное потребителем, обработка может быть перезапущена, если фабрика соединений поддерживает это.

Я продолжаю получать следующее предупреждение на стороне потребителя spring rabbitmq. он продолжает искать перезапуск.

[SimpleAsyncTaskExecutor-3317] WARN  org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer raised exception, processing can restart if the connection factory supports it
    com.rabbitmq.client.ShutdownSignalException: connection error
            at com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:715)
            at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:705)
            at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:567)
            at java.lang.Thread.run(Thread.java:745)
    Caused by: java.net.SocketException: Connection reset
            at java.net.SocketInputStream.read(SocketInputStream.java:189)
            at java.net.SocketInputStream.read(SocketInputStream.java:121)
            at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
            at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
            at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288)
            at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95)
            at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139)
            at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:532)
            ... 1 more

И

[SimpleAsyncTaskExecutor-3316] INFO  org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Restarting Consumer: tags=[[amq.ctag-0o_AANjD6-IsH8H3MGWNnQ]], channel=Cached Rabbit Channel: AMQChannel, acknowledgeMode=AUTO local queue size=0
2016-02-28 06:06:58,634 334085996 [SimpleAsyncTaskExecutor-3317] INFO  org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Restarting Consumer: tags=[[amq.ctag-RXsch0v9cjuRlEB-ck1Lvg]], channel=Cached Rabbit Channel: AMQChannel, acknowledgeMode=AUTO local queue size=0
2016-02-28 06:06:58,651 334086013 [SimpleAsyncTaskExecutor-3318] WARN  org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer raised exception, processing can restart if the connection factory supports it
com.rabbitmq.client.ShutdownSignalException: connection error

java rabbitmq spring-rabbit
person Muni    schedule 28.02.2016    source источник

Ответы (2)


arrow_upward
0
arrow_downward

Если вы видите исключение ниже

java.net.SocketException: Connection reset at java.net.SocketInputStream.read(SocketInputStream.java:189) at java.net.SocketInputStream.read(SocketInputStream.java:121) at java.io.BufferedInputStream.fill(BufferedInputStream.java:246) at java.io.BufferedInputStream.read(BufferedInputStream.java:265) at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288) at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95) at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139) at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:532)

Это означает, что вы закрываете потребителя, не останавливая его.

person Anil    schedule 28.02.2016

arrow_upward
0
arrow_downward

Посмотрите в журнале сервера - сервер принудительно закрыл (сбросил) соединение по какой-то причине.

person Gary Russell    schedule 28.02.2016