Added sending and receiving message queues.
This commit is contained in:
20
src/main/java/queues/src/ReceivingQueue.java
Normal file
20
src/main/java/queues/src/ReceivingQueue.java
Normal file
@@ -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;
|
||||
}
|
||||
}
|
||||
20
src/main/java/queues/src/SendingQueue.java
Normal file
20
src/main/java/queues/src/SendingQueue.java
Normal file
@@ -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;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user