From 2cfadfa312437a8c5158f54eea4c7f4c6e484c6c Mon Sep 17 00:00:00 2001
From: WickedJack99 <wickedjack1@proton.me>
Date: Thu, 28 Dec 2023 21:53:48 +0100
Subject: [PATCH] Added sending and receiving message queues.

---
 src/main/java/queues/src/ReceivingQueue.java | 20 ++++++++++++++++++++
 src/main/java/queues/src/SendingQueue.java   | 20 ++++++++++++++++++++
 2 files changed, 40 insertions(+)
 create mode 100644 src/main/java/queues/src/ReceivingQueue.java
 create mode 100644 src/main/java/queues/src/SendingQueue.java

diff --git a/src/main/java/queues/src/ReceivingQueue.java b/src/main/java/queues/src/ReceivingQueue.java
new file mode 100644
index 0000000..6987cc3
--- /dev/null
+++ b/src/main/java/queues/src/ReceivingQueue.java
@@ -0,0 +1,20 @@
+/**
+ * @author Aaron Moser
+ * @date 26.12.2023
+ */
+package queues.src;
+
+import java.util.concurrent.LinkedBlockingQueue;
+
+public class ReceivingQueue extends LinkedBlockingQueue<String> {
+    private static ReceivingQueue instance;
+
+    private ReceivingQueue() {}
+
+    public static ReceivingQueue getInstance() {
+        if (instance == null) {
+            instance = new ReceivingQueue();
+        }
+        return instance;
+    }
+}
diff --git a/src/main/java/queues/src/SendingQueue.java b/src/main/java/queues/src/SendingQueue.java
new file mode 100644
index 0000000..fe5d287
--- /dev/null
+++ b/src/main/java/queues/src/SendingQueue.java
@@ -0,0 +1,20 @@
+/**
+ * @author Aaron Moser
+ * @date 26.12.2023
+ */
+package queues.src;
+
+import java.util.concurrent.LinkedBlockingQueue;
+
+public class SendingQueue extends LinkedBlockingQueue<String> {
+    private static SendingQueue instance;
+
+    private SendingQueue() {}
+
+    public static SendingQueue getInstance() {
+        if (instance == null) {
+            instance = new SendingQueue();
+        }
+        return instance;
+    }
+}