__init__.py 557 B

12345678910111213141516
  1. # -*- coding: utf-8 -*-
  2. """Monitoring Event Receiver+Dispatcher.
  3. Events is a stream of messages sent for certain actions occurring
  4. in the worker (and clients if :setting:`task_send_sent_event`
  5. is enabled), used for monitoring purposes.
  6. """
  7. from __future__ import absolute_import, unicode_literals
  8. from .dispatcher import EventDispatcher
  9. from .event import Event, event_exchange, get_exchange, group_from
  10. from .receiver import EventReceiver
  11. __all__ = (
  12. 'Event', 'EventDispatcher', 'EventReceiver',
  13. 'event_exchange', 'get_exchange', 'group_from',
  14. )