swh.scheduler.celery_backend.listener module

class swh.scheduler.celery_backend.listener.ReliableEventReceiver(channel, handlers=None, routing_key='#', node_id=None, app=None, queue_prefix='celeryev', accept=None)

Bases: celery.events.receiver.EventReceiver

get_consumers(consumer, channel)

process(type, event, message)

Process the received event by dispatching it to the appropriate handler.

swh.scheduler.celery_backend.listener.event_monitor(app, backend)