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.