| 123456789101112131415161718192021 |
- from .job import TaskRequest
- from ..utils.coroutine import coroutine
- def default(task, app, consumer):
- @coroutine
- def task_message_handler(self):
- logger = consumer.logger
- hostname = consumer.hostname
- eventer = consumer.event_dispatcher
- Request = TaskRequest.from_message
- handle = consumer.on_task
- while 1:
- M, B, A = (yield)
- handle(Request(M, B, A, app=app, logger=logger,
- hostname=hostname, eventer=eventer))
- return task_message_handler()
|
