DATAREDIS-77 Fix for not passing the message channel to message listeners.
This commit is contained in:
@@ -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());
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user