Method register_with_event_loop

celery/worker/consumer/consumer.py:414–418

(self, hub)

                )

    def register_with_event_loop(self, hub):
        self.blueprint.send_all(
            self, 'register_with_event_loop', args=(hub,),
            description='Hub.register',
        )

    def shutdown(self):
        self.perform_pending_operations()