32 lines
910 B
Python
32 lines
910 B
Python
# example_consumer.py
|
|
import pika, os, time
|
|
|
|
def alldcs_process_function(msg):
|
|
# print(" ALLDCS processing")
|
|
# print(" [x] Received " + str(msg))
|
|
print(str(msg))
|
|
|
|
time.sleep(1) # delays for 5 seconds
|
|
# print(" ALLDCS processing finished");
|
|
return;
|
|
|
|
# Access the CLODUAMQP_URL environment variable and parse it (fallback to localhost)
|
|
url = os.environ.get('CLOUDAMQP_URL', 'amqp://guest:guest@localhost:32189/%2f')
|
|
params = pika.URLParameters(url)
|
|
connection = pika.BlockingConnection(params)
|
|
channel = connection.channel() # start a channel
|
|
channel.queue_declare(queue='ALLDCS') # Declare a queue
|
|
|
|
# create a function which is called on incoming messages
|
|
def callback(ch, method, properties, body):
|
|
alldcs_process_function(body)
|
|
|
|
# set up subscription on the queue
|
|
channel.basic_consume('ALLDCS',
|
|
callback,
|
|
auto_ack=True)
|
|
|
|
# start consuming (blocks)
|
|
channel.start_consuming()
|
|
connection.close()
|