echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Python tutorials updated to pika 0.9.5

Browse Source
This commit is contained in:
Marek Majkowski 2011-03-29 14:27:35 +01:00
parent 596faaf044
commit 4597ec0161
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
python/README.md
View File

@ -5,13 +5,13 @@ tutorials](http://www.rabbitmq.com/getstarted.html).
## Requirements ## Requirements
To run this code you need `pika` library version 0.9.4. To install it run To run this code you need `pika` library version 0.9.5. To install it run
pip install -e git+http://github.com/pika/pika.git@v0.9.4#egg=pika-v0.9.4 pip install -e git+http://github.com/pika/pika.git@v0.9.5#egg=pika-v0.9.5
or or
easy_install pika==0.9.4 easy_install pika==0.9.5
## Code ## Code

2
python/rpc_server.py
View File

@ -32,7 +32,7 @@ def on_request(ch, method, props, body):
body=str(response)) body=str(response))
ch.basic_ack(delivery_tag = method.delivery_tag) ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1, prefetch_size=0L) channel.basic_qos(prefetch_count=1)
channel.basic_consume(on_request, queue='rpc_queue') channel.basic_consume(on_request, queue='rpc_queue')
print " [x] Awaiting RPC requests" print " [x] Awaiting RPC requests"

2
python/worker.py
View File

@ -15,7 +15,7 @@ def callback(ch, method, properties, body):
print " [x] Done" print " [x] Done"
ch.basic_ack(delivery_tag = method.delivery_tag) ch.basic_ack(delivery_tag = method.delivery_tag)
channel.basic_qos(prefetch_count=1, prefetch_size=0L) channel.basic_qos(prefetch_count=1)
channel.basic_consume(callback, channel.basic_consume(callback,
queue='task_queue') queue='task_queue')