From 8ea75f00c0203dbadab85e0649bc5b5a0261dd28 Mon Sep 17 00:00:00 2001 From: dynamikdev Date: Fri, 5 Jul 2013 09:29:46 +0200 Subject: [PATCH] Update client.py for knowing the original subscribing pattern in the message receive none-Pattern subscription the channel is the pattern permit multiple subcription and retreive original subscription --- txredis/client.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/txredis/client.py b/txredis/client.py index 4e2e630..67f1f68 100644 --- a/txredis/client.py +++ b/txredis/client.py @@ -1484,10 +1484,10 @@ def handleCompleteMultiBulkData(self, reply): """ if reply[0] == u"message": channel, message = reply[1:] - self.messageReceived(channel, message) + self.messageReceived(channel, message, channel) elif reply[0] == u"pmessage": pattern, channel, message = reply[1:] - self.messageReceived(channel, message) + self.messageReceived(channel, message, pattern) elif reply[0] == u"subscribe": channel, numSubscribed = reply[1:] self.channelSubscribed(channel, numSubscribed) @@ -1503,7 +1503,7 @@ def handleCompleteMultiBulkData(self, reply): else: RedisBase.handleCompleteMultiBulkData(self, reply) - def messageReceived(self, channel, message): + def messageReceived(self, channel, message, pattern): """ Called when this connection is subscribed to a channel that has received a message published on it.