Browse Source

Worker: Crash on channel errors

Ask Solem 12 years ago
parent
commit
5f74f51a23
1 changed files with 1 additions and 1 deletions
  1. 1 1
      celery/worker/consumer.py

+ 1 - 1
celery/worker/consumer.py

@@ -184,7 +184,7 @@ class Consumer(object):
             maybe_shutdown()
             try:
                 ns.start(self)
-            except self.connection_errors + self.channel_errors:
+            except self.connection_errors:
                 maybe_shutdown()
                 if ns.state != CLOSE and self.connection:
                     warn(CONNECTION_RETRY, exc_info=True)