From ed33b050946ed5eee63aab5a2d56820332461f92 Mon Sep 17 00:00:00 2001 From: Brian McFadden Date: Fri, 15 Jul 2011 08:23:19 -0700 Subject: [PATCH] Fixing queue name. --- examples/tutorial6/rpc_server.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/tutorial6/rpc_server.py b/examples/tutorial6/rpc_server.py index 21756d0..d538547 100644 --- a/examples/tutorial6/rpc_server.py +++ b/examples/tutorial6/rpc_server.py @@ -15,7 +15,7 @@ def fib(n): def on_connect(): global ch ch = conn.channel() - ch.queue_declare(queue='task_queue', durable=True) + ch.queue_declare(queue='rpc_queue', durable=True) ch.qos(prefetch_count=1) ch.consume('rpc_queue', on_request)