Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Tidy up fatal error message in for failed listener restart

Browse Source
This commit is contained in:
Dave Syer
2011-08-09 14:41:39 +01:00
parent 6235fc5cf2
commit 86653e145c
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/SimpleMessageListenerContainer.java
View File

@@ -385,9 +385,8 @@ public class SimpleMessageListenerContainer extends AbstractMessageListenerConta
consumer = createBlockingQueueConsumer();
this.consumers.add(consumer);
} catch (RuntimeException e) {
logger.warn("Consumer died on restart. " + e.getClass() + ": " + e.getMessage());
// Thrown into the void (probably) in a background thread.
// Oh well, here goes...
logger.warn("Consumer failed irretrievably on restart. " + e.getClass() + ": " + e.getMessage());
// Re-throw and have it logged properly by the caller.
throw e;
}
this.taskExecutor.execute(new AsyncMessageProcessingConsumer(consumer));