From 131d3d85cb4d035f5d0acfe6dd9df8aff9437051 Mon Sep 17 00:00:00 2001 From: Alex Date: Sun, 2 Jan 2022 20:04:44 +0100 Subject: [PATCH] message handling on receiving --- .../earth/krakatao/protocol/KraSocketClientProtocol.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java index a7d8198..47434f8 100644 --- a/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java +++ b/src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java @@ -17,13 +17,13 @@ public class KraSocketClientProtocol { private final ArrayList cmdIDs; @Getter private int currentCmdIDIndex; - - //@Getter - //HashMap> consumerHashMap = new HashMap<>(); + @Getter + private final HashMap> consumerHashMap; public KraSocketClientProtocol() { this.cmdIDs = new ArrayList<>(); this.currentCmdIDIndex = 10; + this.consumerHashMap = new HashMap<>(); } public int generateCmdID() { @@ -45,7 +45,7 @@ public class KraSocketClientProtocol { kraProtocolMessage.getDest(), kraProtocolMessage.getUuid(), kraProtocolMessage.getCmdNumber(), kraProtocolMessage.getArgs()); } - + public byte[] EncodeMessage(int status, int cmdID, int dest, String uuid, int cmdNumber, String args) { KraSocketClient.getLogger() @@ -84,7 +84,6 @@ public class KraSocketClientProtocol { this.cmdIDs.add(cmdID); return raw; - //ProxySystem.getInstance().getSocketClient().SendMessage(raw); } public KraSocketClientProtocolMessage DecodeMessage(byte[] data) {