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

Handling of message reception

master
Alex 2022-01-03 22:35:48 +01:00
parent abfba326c5
commit 95c404dfce
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/earth/krakatao/SocketClient.java
View File

@ -59,7 +59,8 @@ public class SocketClient extends WebSocketClient {
return; return;
} }
if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.REPLY.getStatus() // response to the user that this message cmdID is already in the queue
if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()
&& this.kraProtocol.getCmdIDs().contains(kraProtocolMessage.getCmdID())) { && this.kraProtocol.getCmdIDs().contains(kraProtocolMessage.getCmdID())) {
// TODO: uuid // TODO: uuid
kraProtocolMessage = new KraSocketClientProtocolMessage( kraProtocolMessage = new KraSocketClientProtocolMessage(
@ -68,19 +69,10 @@ public class SocketClient extends WebSocketClient {
? kraProtocolMessage.getStatus() : 0, 0, ? kraProtocolMessage.getStatus() : 0, 0,
"bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb", (short) kraProtocolMessage.getCmdNumber(), ""); "bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb", (short) kraProtocolMessage.getCmdNumber(), "");
if (this.kraProtocol.getCmdIDs().contains(kraProtocolMessage.getCmdID())) {
this.kraProtocol.getCmdIDs().remove(kraProtocolMessage.getCmdID());
}
this.SendMessage(kraProtocolMessage); this.SendMessage(kraProtocolMessage);
return; return;
} }
if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()
&& this.kraProtocol.getCmdIDs().contains(kraProtocolMessage.getCmdID())) {
this.kraProtocol.getCmdIDs().remove(kraProtocolMessage.getCmdID());
}
this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage); this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
} }