diff options
Diffstat (limited to 'examples/simple_task_queue/worker.py')
| -rw-r--r-- | examples/simple_task_queue/worker.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py index 807542e9..7f62445d 100644 --- a/examples/simple_task_queue/worker.py +++ b/examples/simple_task_queue/worker.py @@ -14,6 +14,7 @@ class Worker(ConsumerMixin): def get_consumers(self, Consumer, channel): return [Consumer(queues=task_queues, + accept=['pickle', 'json'], callbacks=[self.process_task])] def process_task(self, body, message): @@ -30,10 +31,12 @@ class Worker(ConsumerMixin): if __name__ == '__main__': from kombu import Connection from kombu.utils.debug import setup_logging - setup_logging(loglevel='INFO') + # setup root logger + setup_logging(loglevel='INFO', loggers=['']) with Connection('amqp://guest:guest@localhost:5672//') as conn: try: - Worker(conn).run() + worker = Worker(conn) + worker.run() except KeyboardInterrupt: print('bye bye') |