worker.consumer.events

Worker Event Dispatcher Bootstep.

Events -> celery.events.EventDispatcher.

Module Contents

Classes

Events(self,c,task_events=True,without_heartbeat=False,without_gossip=False,**kwargs) Service used for sending monitoring events.
class Events(c, task_events=True, without_heartbeat=False, without_gossip=False, **kwargs)

Service used for sending monitoring events.

__init__(c, task_events=True, without_heartbeat=False, without_gossip=False, **kwargs)
start(c)
stop(c)
_close(c)
shutdown(c)