Propagate Exception

This commit is contained in:
Eric Bottard
2015-08-07 18:19:54 +02:00
committed by Marius Bogoevici
parent 0a84afd6ea
commit 53c228239b

View File

@@ -273,7 +273,7 @@ public class RedisMessageChannelBinder extends MessageChannelBinderSupport imple
public Boolean recover(RetryContext context) throws Exception {
logger.error(
"Failed to deliver message; retries exhausted; message sent to queue 'ERRORS:"
+ name + "' " + context.getLastThrowable());
+ name + "' ", context.getLastThrowable());
errorAdapter.handleMessage(getMessageBuilderFactory().fromMessage(message)
.setHeader(ERROR_HEADER, "ERRORS:" + name)
.build());