From d060d8e7117d5373c0e61f9db8d2905b4d0805a4 Mon Sep 17 00:00:00 2001
From: Malachy Byrne <malachybyrne1@gmail.com>
Date: Thu, 13 Apr 2023 00:43:36 +0100
Subject: [PATCH] added logging queue

---
 functions.py |  8 ++++++++
 log.py       | 24 ++++++++++++++++++++++++
 2 files changed, 32 insertions(+)
 create mode 100644 functions.py
 create mode 100644 log.py

diff --git a/functions.py b/functions.py
new file mode 100644
index 0000000..10fd12c
--- /dev/null
+++ b/functions.py
@@ -0,0 +1,8 @@
+import pika
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials("user", "password")))
+channel = connection.channel()
+
+def log(data):
+    channel.basic_publish(exchange='', routing_key='log', body=data)
+
diff --git a/log.py b/log.py
new file mode 100644
index 0000000..338f516
--- /dev/null
+++ b/log.py
@@ -0,0 +1,24 @@
+import pika
+
+connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials("user", "password")))
+channel = connection.channel()
+
+channel.queue_declare(queue='log')
+
+def log(ch, method, properties, body):
+    try:
+        data = body.decode()
+    except UnicodeDecodeError:
+        data = body
+    print(data)
+
+channel.basic_consume(queue='log', on_message_callback=log, auto_ack=True)
+
+try:
+    print("Opening logs")
+    channel.start_consuming()
+except KeyboardInterrupt:
+    channel.stop_consuming()
+    channel.close()
+    print("Closing logs")
+