echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Print later

Browse Source
This commit is contained in:
Michael Klishin 2015-12-21 06:07:42 +03:00
parent 3b471a45d7
commit 55374bd433
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
python/receive.py
View File

@ -8,8 +8,6 @@ channel = connection.channel()
channel.queue_declare(queue='hello') channel.queue_declare(queue='hello')
print(' [*] Waiting for messages. To exit press CTRL+C')
def callback(ch, method, properties, body): def callback(ch, method, properties, body):
print(" [x] Received %r" % body) print(" [x] Received %r" % body)
@ -17,4 +15,5 @@ channel.basic_consume(callback,
queue='hello', queue='hello',
no_ack=True) no_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming() channel.start_consuming()