Merge branch 'rabbitmq-base-poducer-consumer' into 'version-1b-local-rabbitmq'

Create base producer/consumers

See merge request mmoo97/flask_user_reg!29

message_manager.py

+#!/usr/bin/env python
+import pika
+
+connection = pika.BlockingConnection(
+    pika.ConnectionParameters(host='localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(
+        exchange='direct_logs', queue=queue_name, routing_key="manager")
+
+print(' [*] Waiting for logs. To exit press CTRL+C')
+
+
+def callback(ch, method, properties, body):
+    print(" [x] %r:%r" % (method.routing_key, body))
+    # Todo: Make message manager more functional
+
+
+channel.basic_consume(
+    queue=queue_name, on_message_callback=callback, auto_ack=True)
+
+channel.start_consuming()
\ No newline at end of file

ohpc_consumer.py

+#!/usr/bin/env python
+import pika
+
+connection = pika.BlockingConnection(
+    pika.ConnectionParameters(host='localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(
+        exchange='direct_logs', queue=queue_name, routing_key="ohpc")
+
+print(' [*] Waiting for logs. To exit press CTRL+C')
+
+
+def callback(ch, method, properties, body):
+    print(" [x] %r:%r" % (method.routing_key, body))
+
+
+channel.basic_consume(
+    queue=queue_name, on_message_callback=callback, auto_ack=True)
+
+channel.start_consuming()
\ No newline at end of file

ood_consumer.py

+#!/usr/bin/env python
+import pika
+
+connection = pika.BlockingConnection(
+    pika.ConnectionParameters(host='localhost'))
+channel = connection.channel()
+
+channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
+
+result = channel.queue_declare(queue='', exclusive=True)
+queue_name = result.method.queue
+
+channel.queue_bind(
+        exchange='direct_logs', queue=queue_name, routing_key="ood")
+
+print(' [*] Waiting for logs. To exit press CTRL+C')
+
+
+def callback(ch, method, properties, body):
+    print(" [x] %r:%r" % (method.routing_key, body))
+
+
+channel.basic_consume(
+    queue=queue_name, on_message_callback=callback, auto_ack=True)
+
+channel.start_consuming()
\ No newline at end of file

run.py

@@ -51,20 +51,25 @@ def handle_my_custom_event(json, methods=['GET', 'POST']):
 def ingest_data(json, methods=['GET', 'POST']):
     print (time.strftime("%m-%d-%Y_%H:%M:%S") + '\tQueue request received: ' + str(json))
 
+    # Begin RabbitMQ process. 
     connection = pika.BlockingConnection(
         pika.ConnectionParameters(host='localhost'))
     channel = connection.channel()
 
     channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
 
-    severity = sys.argv[1] if len(sys.argv) > 1 else 'info'
-    message = ' '.join(sys.argv[2:]) or 'Hello World!'
+    message = "Hey there" # todo: account info goes here
+
+    channel.basic_publish(
+        exchange='direct_logs', routing_key="ohpc", body=message)
+    print(" [x] Sent %r:%r" % ("ohpc", message))
+
     channel.basic_publish(
-        exchange='direct_logs', routing_key=severity, body=message)
-    print(" [x] Sent %r:%r" % (severity, message))
+        exchange='direct_logs', routing_key="ood", body=message)
+    print(" [x] Sent %r:%r" % ("ood", message))
     connection.close()
 
-    # Todo: Make the remaining protion of this method in a RabbitMQ consumer
+    # Todo: Make the remaining portion of this method in a RabbitMQ consumer
 
     # try:
     #     fullname = json["fullname"]