Fixing queue name.

paolo-losi · Jul 15, 2011 · ed33b05 · ed33b05
1 parent 0f60d6f
commit ed33b05
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)