summaryrefslogtreecommitdiff
path: root/examples/simple_task_queue
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2012-06-24 16:32:17 +0100
committerAsk Solem <ask@celeryproject.org>2012-06-24 16:32:17 +0100
commitfa816f6dc920aeb7b68b75f98fa1656da57d05c8 (patch)
treec2f2d076cc62ea62405fb6f267accab61d1f67c9 /examples/simple_task_queue
parent4922c4aaea77be7a32a7d904104b055159e0da3e (diff)
downloadkombu-fa816f6dc920aeb7b68b75f98fa1656da57d05c8.tar.gz
BrokerConnection is now Connection in docs
Diffstat (limited to 'examples/simple_task_queue')
-rw-r--r--examples/simple_task_queue/client.py24
-rw-r--r--examples/simple_task_queue/queues.py8
-rw-r--r--examples/simple_task_queue/worker.py20
3 files changed, 26 insertions, 26 deletions
diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py
index 1ab6175a..e07b8c45 100644
--- a/examples/simple_task_queue/client.py
+++ b/examples/simple_task_queue/client.py
@@ -5,25 +5,25 @@ from kombu.pools import producers
from queues import task_exchange
-priority_to_routing_key = {"high": "hipri",
- "mid": "midpri",
- "low": "lopri"}
+priority_to_routing_key = {'high': 'hipri',
+ 'mid': 'midpri',
+ 'low': 'lopri'}
-def send_as_task(connection, fun, args=(), kwargs={}, priority="mid"):
- payload = {"fun": fun, "args": args, "kwargs": kwargs}
+def send_as_task(connection, fun, args=(), kwargs={}, priority='mid'):
+ payload = {'fun': fun, 'args': args, 'kwargs': kwargs}
routing_key = priority_to_routing_key[priority]
with producers[connection].acquire(block=True) as producer:
maybe_declare(task_exchange, producer.channel)
- producer.publish(payload, serializer="pickle",
- compression="bzip2",
+ producer.publish(payload, serializer='pickle',
+ compression='bzip2',
routing_key=routing_key)
-if __name__ == "__main__":
- from kombu import BrokerConnection
+if __name__ == '__main__':
+ from kombu import Connection
from tasks import hello_task
- connection = BrokerConnection("amqp://guest:guest@localhost:5672//")
- send_as_task(connection, fun=hello_task, args=("Kombu", ), kwargs={},
- priority="high")
+ connection = Connection('amqp://guest:guest@localhost:5672//')
+ send_as_task(connection, fun=hello_task, args=('Kombu', ), kwargs={},
+ priority='high')
diff --git a/examples/simple_task_queue/queues.py b/examples/simple_task_queue/queues.py
index 680e7575..602c2b0e 100644
--- a/examples/simple_task_queue/queues.py
+++ b/examples/simple_task_queue/queues.py
@@ -1,6 +1,6 @@
from kombu import Exchange, Queue
-task_exchange = Exchange("tasks", type="direct")
-task_queues = [Queue("hipri", task_exchange, routing_key="hipri"),
- Queue("midpri", task_exchange, routing_key="midpri"),
- Queue("lopri", task_exchange, routing_key="lopri")]
+task_exchange = Exchange('tasks', type='direct')
+task_queues = [Queue('hipri', task_exchange, routing_key='hipri'),
+ Queue('midpri', task_exchange, routing_key='midpri'),
+ Queue('lopri', task_exchange, routing_key='lopri')]
diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py
index 063a6b4d..3d933c4b 100644
--- a/examples/simple_task_queue/worker.py
+++ b/examples/simple_task_queue/worker.py
@@ -16,23 +16,23 @@ class Worker(ConsumerMixin):
callbacks=[self.process_task])]
def process_task(self, body, message):
- fun = body["fun"]
- args = body["args"]
- kwargs = body["kwargs"]
- self.info("Got task: %s", reprcall(fun.__name__, args, kwargs))
+ fun = body['fun']
+ args = body['args']
+ kwargs = body['kwargs']
+ self.info('Got task: %s', reprcall(fun.__name__, args, kwargs))
try:
fun(*args, **kwdict(kwargs))
except Exception, exc:
- self.error("task raised exception: %r", exc)
+ self.error('task raised exception: %r', exc)
message.ack()
-if __name__ == "__main__":
- from kombu import BrokerConnection
+if __name__ == '__main__':
+ from kombu import Connection
from kombu.utils.debug import setup_logging
- setup_logging(loglevel="INFO")
+ setup_logging(loglevel='INFO')
- with BrokerConnection("amqp://guest:guest@localhost:5672//") as conn:
+ with Connection('amqp://guest:guest@localhost:5672//') as conn:
try:
Worker(conn).run()
except KeyboardInterrupt:
- print("bye bye")
+ print('bye bye')