format publish

2011-04-14 15:27:11 +01:00 · 2011-04-14 15:27:11 +01:00 · 7052600011
commit 7052600011
parent 7251e9b5ac
1 changed files with 2 additions and 1 deletions
--- a/python/new_task.py
+++ b/python/new_task.py
@ -9,7 +9,8 @@ channel = connection.channel()
 channel.queue_declare(queue='task_queue', durable=True)

 message = ' '.join(sys.argv[1:]) or "Hello World!"
-channel.basic_publish(exchange='', routing_key='task_queue',
+channel.basic_publish(exchange='',
+                      routing_key='task_queue',
                      body=message,
                      properties=pika.BasicProperties(
                         delivery_mode = 2, # make message persistent