From f0ab8812a37b916e3a6b079c607a2db5a902847b Mon Sep 17 00:00:00 2001 From: Alex Date: Tue, 15 Mar 2022 14:42:27 +0100 Subject: [PATCH] method added to make it easier to reply that we have received the ack message --- .../protocol/KraSocketClientProtocol.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java index d69e405..d514f7c 100644 --- a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java +++ b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java @@ -2,6 +2,7 @@ package earth.krakatao.protocol; import earth.krakatao.Formatter; import earth.krakatao.KraSocketClient; +import earth.krakatao.SocketClient; import java.nio.charset.StandardCharsets; import java.text.Format; import java.text.Normalizer.Form; @@ -159,4 +160,18 @@ public class KraSocketClientProtocol { public void removeMessageFromReceivedQueue(int cmdID) { this.receivedQueueMessages.remove(cmdID); } + + // This method is used to send a reply message to the backend that we have received the ack message. + public void replyToBackendThatWeReceivedMessage(SocketClient socketClient, + KraSocketClientProtocol kraSocketClientProtocol, int cmdID, byte dest, UUID uuid, + int cmdNumber) { + KraSocketClientProtocolMessage kraSocketClientProtocolMessage = new KraSocketClientProtocolMessage( + KraSocketClientProtocolStatus.REPLY.getStatus(), cmdID, + KraSocketClientProtocolDest.BACKEND.getStatus(), uuid, + cmdNumber, "", null); + + socketClient.SendMessage(kraSocketClientProtocolMessage); + + kraSocketClientProtocol.removeMessageFromReceivedQueue(cmdID); + } }