diff --git a/txredisapi.py b/txredisapi.py
index 24774f2..7863d7c 100644
--- a/txredisapi.py
+++ b/txredisapi.py
@@ -1916,9 +1916,9 @@ def messageReceived(self, pattern, channel, message):
     def replyReceived(self, reply):
         if isinstance(reply, list):
             reply_len = len(reply)
-            if reply_len >= 3 and reply[-3] == u"message":
+            if reply_len >= 3 and reply[-3] in (u"message", b"message"):
                 self.messageReceived(None, *reply[-2:])
-            elif reply_len >= 4 and reply[-4] == u"pmessage":
+            elif reply_len >= 4 and reply[-4] in (u"pmessage", b"pmessage"):
                 self.messageReceived(*reply[-3:])
             elif reply_len >= 3 and reply[-3] in self._sub_unsub_reponses and len(self.replyQueue.waiting) == 0:
                 pass