Don't use LogMixin. Closes #169

1 files changed, 5 insertions, 2 deletions

diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py
index 3d933c4b..be241140 100644
--- a/examples/simple_task_queue/worker.py
+++ b/examples/simple_task_queue/worker.py
@@ -1,10 +1,13 @@
 from __future__ import with_statement
 
 from kombu.mixins import ConsumerMixin
+from kombu.log import get_logger
 from kombu.utils import kwdict, reprcall
 
 from queues import task_queues
 
+logger = get_logger(__name__)
+
 
 class Worker(ConsumerMixin):
 
@@ -19,11 +22,11 @@ class Worker(ConsumerMixin):
         fun = body['fun']
         args = body['args']
         kwargs = body['kwargs']
-        self.info('Got task: %s', reprcall(fun.__name__, args, kwargs))
+        logger.info('Got task: %s', reprcall(fun.__name__, args, kwargs))
         try:
             fun(*args, **kwdict(kwargs))
         except Exception, exc:
-            self.error('task raised exception: %r', exc)
+            logger.error('task raised exception: %r', exc)
         message.ack()
 
 if __name__ == '__main__':