Not consuming responses for subscribe commands.

dbravender · Mar 31, 2010 · b33a6fc · b33a6fc
1 parent 7b1f196
commit b33a6fc
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/redis/client.py b/redis/client.py
@@ -258,17 +258,15 @@ def _execute_command(self, command_name, command, **options):
                 "UNSUBSCRIBE while channels are open")
         try:
             self.connection.send(command, self)
-            response = self.parse_response(command_name, **options)
             if subscription_command:
                 return None
-            return response
+            return self.parse_response(command_name, **options)
         except ConnectionError:
             self.connection.disconnect()
             self.connection.send(command, self)
-            response = self.parse_response(command_name, **options)
             if subscription_command:
                 return None
-            return response
+            return self.parse_response(command_name, **options)
 
     def execute_command(self, *args, **options):
         "Sends the command to the redis server and returns it's response"