From 6f86b1b2388d7cc1b5d03caa2e29d71f9ad1d1f5 Mon Sep 17 00:00:00 2001
From: Alex <alex@roese.dev>
Date: Mon, 28 Feb 2022 20:01:55 +0100
Subject: [PATCH] Adding the message to the queue when the status is ack

---
 src/main/java/earth/krakatao/SocketClient.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/main/java/earth/krakatao/SocketClient.java b/src/main/java/earth/krakatao/SocketClient.java
index 52360ee..4e6d1f3 100644
--- a/src/main/java/earth/krakatao/SocketClient.java
+++ b/src/main/java/earth/krakatao/SocketClient.java
@@ -2,6 +2,7 @@ package earth.krakatao;
 
 import earth.krakatao.events.KraSocketClientEventInitiater;
 import earth.krakatao.protocol.KraSocketClientProtocol;
+import earth.krakatao.protocol.KraSocketClientProtocolDest;
 import earth.krakatao.protocol.KraSocketClientProtocolMessage;
 import earth.krakatao.protocol.KraSocketClientProtocolStatus;
 import java.net.URI;
@@ -33,6 +34,10 @@ public class SocketClient extends WebSocketClient {
 
   public void SendMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
     if (isOpen()) {
+      if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()) {
+        this.kraProtocol.getSendQueueMessages()
+            .put(kraProtocolMessage.getCmdID(), kraProtocolMessage);
+      }
       send(this.kraProtocol.EncodeMessage(kraProtocolMessage));
     }
   }