From 894a3c7f16c1525cda28ae52d3ac346a6c2fbda9 Mon Sep 17 00:00:00 2001
From: Alex <alex@roese.dev>
Date: Tue, 15 Mar 2022 14:11:49 +0100
Subject: [PATCH] added received queue messages list

---
 .../earth/krakatao/protocol/KraSocketClientProtocol.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
index 8006718..d69e405 100644
--- a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
+++ b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
@@ -23,12 +23,15 @@ public class KraSocketClientProtocol {
 
   @Getter
   private final HashMap<Integer, KraSocketClientProtocolMessage> sendQueueMessages;
+  @Getter
+  private final HashMap<Integer, KraSocketClientProtocolMessage> receivedQueueMessages;
 
   public KraSocketClientProtocol() {
     //this.cmdIDs = new ArrayList<>();
     this.currentCmdIDIndex = 9;
     //this.consumerHashMap = new HashMap<>();
     this.sendQueueMessages = new HashMap<>();
+    this.receivedQueueMessages = new HashMap<>();
   }
 
   public int generateCmdID() {
@@ -152,4 +155,8 @@ public class KraSocketClientProtocol {
 
     this.consumerHashMap.remove(cmdID); */
   }
+
+  public void removeMessageFromReceivedQueue(int cmdID) {
+    this.receivedQueueMessages.remove(cmdID);
+  }
 }