We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d8ab36c commit 4f08455Copy full SHA for 4f08455
python/new_task.py
@@ -9,7 +9,8 @@
9
channel.queue_declare(queue='task_queue', durable=True)
10
11
message = ' '.join(sys.argv[1:]) or "Hello World!"
12
-channel.basic_publish(exchange='', routing_key='task_queue',
+channel.basic_publish(exchange='',
13
+ routing_key='task_queue',
14
body=message,
15
properties=pika.BasicProperties(
16
delivery_mode = 2, # make message persistent
0 commit comments