Krakatoa-Earth
/
KraSocketClient
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

added received queue messages list

master
Alex 2022-03-15 14:11:49 +01:00
parent ba3f361ac1
commit 894a3c7f16
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/earth/krakatao/protocol/KraSocketClientProtocol.java
View File

@ -23,12 +23,15 @@ public class KraSocketClientProtocol {
@Getter @Getter
private final HashMap<Integer, KraSocketClientProtocolMessage> sendQueueMessages; private final HashMap<Integer, KraSocketClientProtocolMessage> sendQueueMessages;
@Getter
private final HashMap<Integer, KraSocketClientProtocolMessage> receivedQueueMessages;
public KraSocketClientProtocol() { public KraSocketClientProtocol() {
//this.cmdIDs = new ArrayList<>(); //this.cmdIDs = new ArrayList<>();
this.currentCmdIDIndex = 9; this.currentCmdIDIndex = 9;
//this.consumerHashMap = new HashMap<>(); //this.consumerHashMap = new HashMap<>();
this.sendQueueMessages = new HashMap<>(); this.sendQueueMessages = new HashMap<>();
this.receivedQueueMessages = new HashMap<>();
} }
public int generateCmdID() { public int generateCmdID() {
@ -152,4 +155,8 @@ public class KraSocketClientProtocol {
this.consumerHashMap.remove(cmdID); */ this.consumerHashMap.remove(cmdID); */
} }
public void removeMessageFromReceivedQueue(int cmdID) {
this.receivedQueueMessages.remove(cmdID);
}
} }