From 53c228239bde86ae988d02c6f029a888b653b089 Mon Sep 17 00:00:00 2001 From: Eric Bottard Date: Fri, 7 Aug 2015 18:19:54 +0200 Subject: [PATCH] Propagate Exception --- .../cloud/stream/binder/redis/RedisMessageChannelBinder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream-binders/spring-cloud-stream-binder-redis/src/main/java/org/springframework/cloud/stream/binder/redis/RedisMessageChannelBinder.java b/spring-cloud-stream-binders/spring-cloud-stream-binder-redis/src/main/java/org/springframework/cloud/stream/binder/redis/RedisMessageChannelBinder.java index 2bd3b1fa2..ac80dc493 100644 --- a/spring-cloud-stream-binders/spring-cloud-stream-binder-redis/src/main/java/org/springframework/cloud/stream/binder/redis/RedisMessageChannelBinder.java +++ b/spring-cloud-stream-binders/spring-cloud-stream-binder-redis/src/main/java/org/springframework/cloud/stream/binder/redis/RedisMessageChannelBinder.java @@ -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());