Skip to content

Commit

Permalink
Fixed: SubscriberProtocol.*subscribe() returned stale deferred.
Browse files Browse the repository at this point in the history
Deferred returned by these methods was waiting for data to appear in replyQueue which never happened. Fixed this by submitting message type name to replyQueue if the type is anything but 'message'.
  • Loading branch information
tonylazarew committed Aug 22, 2012
1 parent 5f9e76e commit 29b0679
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions txredisapi.py
Expand Up @@ -1331,6 +1331,7 @@ def replyReceived(self, reply):
if reply[-3] == u"message":
self.messageReceived(None, *reply[-2:])
else:
self.replyQueue.put(reply[-3])
self.messageReceived(*reply[-3:])

def subscribe(self, channels):
Expand Down

0 comments on commit 29b0679

Please sign in to comment.