From 1b1ac1c07b9c94dad79c59a8b28209e94e0e779e Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 22 Feb 2016 17:14:38 -0500 Subject: [PATCH] use correct name for Redis consumer Binding --- .../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 141c1644b..b1894bc9c 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 @@ -178,7 +178,7 @@ public class RedisMessageChannelBinder extends AbstractBinder { adapter.setOutputChannel(bridgeInputChannel); adapter.setBeanName("inbound." + channelName); adapter.afterPropertiesSet(); - DefaultBinding consumerBinding = new DefaultBinding(channelName, group, moduleInputChannel, adapter, properties) { + DefaultBinding consumerBinding = new DefaultBinding(bindingName, group, moduleInputChannel, adapter, properties) { @Override protected void afterUnbind() {