Merge pull request #15 from jamescarr/AMQP-200
This commit is contained in:
@@ -34,6 +34,7 @@ import com.rabbitmq.client.Channel;
|
||||
* @author Mark Pollack
|
||||
* @author Mark Fisher
|
||||
* @author Dave Syer
|
||||
* @author James Carr
|
||||
*/
|
||||
public abstract class AbstractMessageListenerContainer extends RabbitAccessor implements BeanNameAware, DisposableBean,
|
||||
SmartLifecycle {
|
||||
@@ -422,11 +423,8 @@ public abstract class AbstractMessageListenerContainer extends RabbitAccessor im
|
||||
protected void invokeErrorHandler(Throwable ex) {
|
||||
if (this.errorHandler != null) {
|
||||
this.errorHandler.handleError(ex);
|
||||
} else if (logger.isDebugEnabled()) {
|
||||
logger.debug("Execution of Rabbit message listener failed, and no ErrorHandler has been set.", ex);
|
||||
} else if (logger.isInfoEnabled()) {
|
||||
logger.info("Execution of Rabbit message listener failed, and no ErrorHandler has been set: "
|
||||
+ ex.getClass() + ": " + ex.getMessage());
|
||||
} else if (logger.isWarnEnabled()) {
|
||||
logger.warn("Execution of Rabbit message listener failed, and no ErrorHandler has been set.", ex);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user