format publish
This commit is contained in:
parent
d8ab36c82a
commit
4f084556ea
@ -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
|
||||
|
Loading…
Reference in New Issue
Block a user