org.springframework.amqp.rabbit.listener.FatalListenerStartupException: Cannot set basicQos.

Spring JIRA | Gary Russell | 2 years ago
  1. 0

    {{SimpleMessageListenerContainer}} If a connection reset occurs in the (tiny) timing window between declaring the queue and setting {{basicQos}}, the container is stopped due to a fatal error. This could occur if a network connection is re-broken soon after being re-established. {{basicQos}} calls that fail due to a connection reset should not be considered fatal since it's likely a transient error. {noformat} 2015-01-24 22:14:51.104 SimpleMessageListenerContainer [ERROR] Consumer received fatal exception on startup ,tomcat_thread=SimpleAsyncTaskExecutor-64 org.springframework.amqp.rabbit.listener.FatalListenerStartupException: Cannot set basicQos. at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:418) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:963) at java.lang.Thread.run(Thread.java:722) Caused by: java.io.IOException at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124) at com.rabbitmq.client.impl.ChannelN.basicQos(ChannelN.java:599) at com.rabbitmq.client.impl.ChannelN.basicQos(ChannelN.java:613) at sun.reflect.GeneratedMethodAccessor105.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:601) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:536) at $Proxy87.basicQos(Unknown Source) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:414) ... 2 more Caused by: com.rabbitmq.client.ShutdownSignalException: connection error at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67) at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33) at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343) at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118) ... 10 more 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:235) at java.io.BufferedInputStream.read(BufferedInputStream.java:254) 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 2015-01-24 22:14:51.161 SimpleMessageListenerContainer [ERROR] Stopping container from aborted consumer ,tomcat_thread=SimpleAsyncTaskExecutor-51 {noformat}

    Spring JIRA | 2 years ago | Gary Russell
    org.springframework.amqp.rabbit.listener.FatalListenerStartupException: Cannot set basicQos.
  2. 0

    {{SimpleMessageListenerContainer}} If a connection reset occurs in the (tiny) timing window between declaring the queue and setting {{basicQos}}, the container is stopped due to a fatal error. This could occur if a network connection is re-broken soon after being re-established. {{basicQos}} calls that fail due to a connection reset should not be considered fatal since it's likely a transient error. {noformat} 2015-01-24 22:14:51.104 SimpleMessageListenerContainer [ERROR] Consumer received fatal exception on startup ,tomcat_thread=SimpleAsyncTaskExecutor-64 org.springframework.amqp.rabbit.listener.FatalListenerStartupException: Cannot set basicQos. at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:418) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:963) at java.lang.Thread.run(Thread.java:722) Caused by: java.io.IOException at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124) at com.rabbitmq.client.impl.ChannelN.basicQos(ChannelN.java:599) at com.rabbitmq.client.impl.ChannelN.basicQos(ChannelN.java:613) at sun.reflect.GeneratedMethodAccessor105.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:601) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:536) at $Proxy87.basicQos(Unknown Source) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:414) ... 2 more Caused by: com.rabbitmq.client.ShutdownSignalException: connection error at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67) at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33) at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343) at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118) ... 10 more 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:235) at java.io.BufferedInputStream.read(BufferedInputStream.java:254) 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 2015-01-24 22:14:51.161 SimpleMessageListenerContainer [ERROR] Stopping container from aborted consumer ,tomcat_thread=SimpleAsyncTaskExecutor-51 {noformat}

    Spring JIRA | 2 years ago | Gary Russell
    org.springframework.amqp.rabbit.listener.FatalListenerStartupException: Cannot set basicQos.
  3. 0

    When sending message getting SocketException: (Connection Reset, AmqpIOException: java.io.IOException)

    Stack Overflow | 2 years ago | Kevin - NOAA Affiliate
    org.springframework.messaging.MessageHandlingException: error occurred in message handler [org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint#0]; nested exception is org.springframework.amqp.AmqpIOException: java.io.IOException
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Trying to migrate over from <rabbit:> xml name space config to a java @Configurable cannot replicate

    Stack Overflow | 2 years ago
    org.springframework.amqp.AmqpIOException: java.io.IOException

  1. max 1 times, last 10 months ago
5 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.net.SocketException

    Connection reset

    at java.net.SocketInputStream.read()
  2. Java RT
    DataInputStream.readUnsignedByte
    1. java.net.SocketInputStream.read(SocketInputStream.java:189)
    2. java.net.SocketInputStream.read(SocketInputStream.java:121)
    3. java.io.BufferedInputStream.fill(BufferedInputStream.java:235)
    4. java.io.BufferedInputStream.read(BufferedInputStream.java:254)
    5. java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288)
    5 frames
  3. RabbitMQ Java Client
    AMQConnection$MainLoop.run
    1. com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95)
    2. com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139)
    3. com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:532)
    3 frames
  4. Java RT
    Thread.run
    1. java.lang.Thread.run(Thread.java:722)
    1 frame