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

Merge pull request #275 from karl-johan-grahn/python-tutorial-1-keyboardinterrupt

Browse Source 
Python Tutorial 1 - Handle KeyboardInterupt
This commit is contained in:
Michael Klishin 2020-08-27 15:25:20 +03:00 committed by GitHub
commit 0076462d7d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
python/receive.py
View File

@ -1,19 +1,26 @@
#!/usr/bin/env python #!/usr/bin/env python
import pika import pika, sys, os
connection = pika.BlockingConnection( def main():
pika.ConnectionParameters(host='localhost')) connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel() channel = connection.channel()
channel.queue_declare(queue='hello') channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
def callback(ch, method, properties, body): channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
print(" [x] Received %r" % body)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
channel.basic_consume( if __name__ == '__main__':
queue='hello', on_message_callback=callback, auto_ack=True) try:
main()
print(' [*] Waiting for messages. To exit press CTRL+C') except KeyboardInterrupt:
channel.start_consuming() print('Interrupted')
try:
sys.exit(0)
except SystemExit:
os._exit(0)