diff --git a/agent_template.py b/agent_template.py new file mode 100644 index 0000000000000000000000000000000000000000..c6e722338bad04999621bd7dfd47a41d2b962d28 --- /dev/null +++ b/agent_template.py @@ -0,0 +1,32 @@ +#!/usr/bin/env python +import sys +import json +from rc_rmq import RCRMQ + +task = 'task_name' + +# Instantiate rabbitmq object +rc_rmq = RCRMQ({'exchange': 'RegUsr', 'exchange_type': 'topic'}) + +# Define your callback function +def on_message(ch, method, properties, body): + + # Retrieve routing key + routing_key = method.routing_key + + # Retrieve message + msg = json.loads(body) + + # Do Something + print('[{}]: Callback called.'.format(task)) + + # Acknowledge message + ch.basic_ack(delivery_tag=method.delivery_tag) + + +print("Start listening to queue: {}".format(task)) +rc_rmq.start_consume({ + 'queue': task, # Define your Queue name + 'routing_key': "#", # Define your routing key + 'cb': on_message # Pass in callback function you just define +})