Skip to content

Commit 4597ec0

Browse files
committed
Python tutorials updated to pika 0.9.5
1 parent 596faaf commit 4597ec0

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

python/README.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,13 @@ tutorials](http://www.rabbitmq.com/getstarted.html).
55

66
## Requirements
77

8-
To run this code you need `pika` library version 0.9.4. To install it run
8+
To run this code you need `pika` library version 0.9.5. To install it run
99

10-
pip install -e git+http://github.com/pika/pika.git@v0.9.4#egg=pika-v0.9.4
10+
pip install -e git+http://github.com/pika/pika.git@v0.9.5#egg=pika-v0.9.5
1111

1212
or
1313

14-
easy_install pika==0.9.4
14+
easy_install pika==0.9.5
1515

1616

1717
## Code

python/rpc_server.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ def on_request(ch, method, props, body):
3232
body=str(response))
3333
ch.basic_ack(delivery_tag = method.delivery_tag)
3434

35-
channel.basic_qos(prefetch_count=1, prefetch_size=0L)
35+
channel.basic_qos(prefetch_count=1)
3636
channel.basic_consume(on_request, queue='rpc_queue')
3737

3838
print " [x] Awaiting RPC requests"

python/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ def callback(ch, method, properties, body):
1515
print " [x] Done"
1616
ch.basic_ack(delivery_tag = method.delivery_tag)
1717

18-
channel.basic_qos(prefetch_count=1, prefetch_size=0L)
18+
channel.basic_qos(prefetch_count=1)
1919
channel.basic_consume(callback,
2020
queue='task_queue')
2121

0 commit comments

Comments
 (0)