examples should match the text

majek · majek · commit 8bfa40e87f98 · 2010-10-07T16:47:05.000+01:00
diff --git a/python/new_task.py b/python/new_task.py
@@ -7,10 +7,10 @@
         credentials=pika.PlainCredentials('guest', 'guest')))
 channel = connection.channel()
 
-channel.queue_declare(queue='test_dur', durable=True)
+channel.queue_declare(queue='task_queue', durable=True)
 
 message = ' '.join(sys.argv[1:]) or "Hello World!"
-channel.basic_publish(exchange='', routing_key='test',
+channel.basic_publish(exchange='', routing_key='task_queue',
                       body=message,
                       properties=pika.BasicProperties(
                          delivery_mode = 2, # make message persistent
diff --git a/python/receive.py b/python/receive.py
@@ -11,7 +11,6 @@
 
 print ' [*] Waiting for messages. To exit press CTRL+C'
 
-
 def callback(ch, method, header, body):
     print " [x] Received %.20r" % (body,)
 
diff --git a/python/tutorial-two.mdx b/python/tutorial-two.mdx
@@ -298,7 +298,7 @@ Final code of our `new_task.py` script:
     channel.queue_declare(queue='task_queue', durable=True)
 
     message = ' '.join(sys.argv[1:]) or "Hello World!"
-    channel.basic_publish(exchange='', routing_key='test',
+    channel.basic_publish(exchange='', routing_key='task_queue',
                           body=message,
                           properties=pika.BasicProperties(
                              delivery_mode = 2, # make message persistent
@@ -320,7 +320,7 @@ And our worker:
             credentials=pika.PlainCredentials('guest', 'guest')))
     channel = connection.channel()
 
-    channel.queue_declare(queue='test')
+    channel.queue_declare(queue='task_queue', durable=True)
     print ' [*] Waiting for messages. To exit press CTRL+C'
 
     def callback(ch, method, header, body):
@@ -331,7 +331,7 @@ And our worker:
 
     channel.basic_qos(prefetch_count=1)
     channel.basic_consume(callback,
-                          queue='test')
+                          queue='task_queue')
 
     pika.asyncore_loop()
 {% endhighlight %}
diff --git a/python/worker.py b/python/worker.py
@@ -7,7 +7,7 @@
         credentials=pika.PlainCredentials('guest', 'guest')))
 channel = connection.channel()
 
-channel.queue_declare(queue='test')
+channel.queue_declare(queue='task_queue', durable=True)
 print ' [*] Waiting for messages. To exit press CTRL+C'
 
 def callback(ch, method, header, body):
@@ -18,7 +18,7 @@ def callback(ch, method, header, body):
 
 channel.basic_qos(prefetch_count=1)
 channel.basic_consume(callback,
-                      queue='test')
+                      queue='task_queue')
 
 pika.asyncore_loop()
 
