Permalink
Browse files

Ensure that deferreds returned by SubscriberProtocol methods will err…

…back() for lost connections (and other errors)
  • Loading branch information...
akgood committed Aug 31, 2012
1 parent 76d4df1 commit 295ee2177f8eb1289f514c42f1ea99e2482c30c9
Showing with 2 additions and 0 deletions.
  1. +2 −0 txredisapi.py
View
@@ -1327,6 +1327,8 @@ def replyReceived(self, reply):
else:
self.replyQueue.put(reply[-3])
self.messageReceived(*reply[-3:])
+ elif isinstance(reply, Exception):
+ self.replyQueue.put(reply)
def subscribe(self, channels):
if isinstance(channels, (str, unicode)):

0 comments on commit 295ee21

Please sign in to comment.