Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/usr/bin/env python
- import pika
- url = os.environ.get('QUEUE_URL')
- params = pika.URLParameters(url)
- params.socket_timeout = 5
- connection = pika.BlockingConnection(params)
- channel = connection.channel()
- channel.queue_declare(queue='hello')
- def callback(ch, method, properties, body):
- print(" [x] Received %r" % body)
- channel.basic_consume(callback,
- queue='hello',
- no_ack=True)
- print(' [*] Waiting for messages. To exit press CTRL+C')
- channel.start_consuming()
- pika.exceptions.ProbableAuthenticationError
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement