Method drain_events

celery/backends/rpc.py:66–71

(self, timeout=None)

        self._consumer.consume()

    def drain_events(self, timeout=None):
        if self._connection:
            with self.reconnect_on_error():
                return self._connection.drain_events(timeout=timeout)
        elif timeout:
            time.sleep(timeout)

    def _reconnect(self):
        """Close the stale connection and rebuild the consumer.