Merge pull request #1 from objectrocket/consumer-reconnect

Attempting to resolve consumer issue with rabbitmq reconnections

Author: naemono

taskflow/engines/worker_based/proxy.py

@@ -216,6 +216,10 @@ def _drain_errback(exc, interval):
                 self._running.set()
                 try:
                     while self._running.is_set():
+                        # This seems to be required when failures occur in
+                        #  rabbitmq, as the consumer doesn't show up in rabbit
+                        #  as a valid consumer without it. (mmontgomery)
+                        consumer.consume()
                         safe_drain(conn, self._drain_events_timeout)
                         if self._on_wait is not None:
                             self._on_wait()