celery.worker.consumer.events¶

Worker Event Dispatcher Bootstep.

Events -> celery.events.EventDispatcher.

class celery.worker.consumer.events.Events(c, task_events=True, without_heartbeat=False, without_gossip=False, **kwargs)[source]¶

Service used for sending monitoring events.

name = 'celery.worker.consumer.events.Events'¶

requires = (step:celery.worker.consumer.connection.Connection{()},)¶

shutdown(c)[source]¶

start(c)[source]¶

stop(c)[source]¶