diff --git a/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java b/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java
index 75c314f74..4cf368b55 100644
--- a/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java
+++ b/src/main/java/org/springframework/data/redis/listener/RedisMessageListenerContainer.java
@@ -721,7 +721,7 @@ public class RedisMessageListenerContainer implements InitializingBean, Disposab
 				taskExecutor.execute(new Runnable() {
 					
 					public void run() {
-						processMessage(messageListener, message, null);
+						processMessage(messageListener, message, message.getChannel());
 					}
 				});
 			}