SimpleMessageListenerContainer一樣 - 消費引發的異常，如果連接工廠支持它

我不斷收到在我的春天RabbitMQ的消費方以下警告處理可以重新啓動。它一直在尋找重新啓動。SimpleMessageListenerContainer一樣 - 消費引發的異常，如果連接工廠支持它

[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

來源

2016-02-28 Muni

你有沒有解決呢？ – Katerina

如果你看到下面

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)

異常這意味着你關閉了消費者，不停止。

來源

2016-02-28 06:36:33 Anil

在服務器中的日誌一看 - 服務器強制關閉（復位）出於某種原因的連接。

來源

2016-02-28 14:44:00

SimpleMessageListenerContainer一樣 - 消費引發的異常，如果連接工廠支持它

回答

相關問題