diff options
| author | Ask Solem <ask@celeryproject.org> | 2012-06-24 16:32:17 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2012-06-24 16:32:17 +0100 |
| commit | fa816f6dc920aeb7b68b75f98fa1656da57d05c8 (patch) | |
| tree | c2f2d076cc62ea62405fb6f267accab61d1f67c9 /examples/simple_task_queue | |
| parent | 4922c4aaea77be7a32a7d904104b055159e0da3e (diff) | |
| download | kombu-fa816f6dc920aeb7b68b75f98fa1656da57d05c8.tar.gz | |
BrokerConnection is now Connection in docs
Diffstat (limited to 'examples/simple_task_queue')
| -rw-r--r-- | examples/simple_task_queue/client.py | 24 | ||||
| -rw-r--r-- | examples/simple_task_queue/queues.py | 8 | ||||
| -rw-r--r-- | examples/simple_task_queue/worker.py | 20 |
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') |
