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

Adding the message to the queue when the status is ack

master
Alex 2022-02-28 20:01:55 +01:00
parent 2edcac5b66
commit 6f86b1b238
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2,6 +2,7 @@ package earth.krakatao;
import earth.krakatao.events.KraSocketClientEventInitiater; import earth.krakatao.events.KraSocketClientEventInitiater;
import earth.krakatao.protocol.KraSocketClientProtocol; import earth.krakatao.protocol.KraSocketClientProtocol;
import earth.krakatao.protocol.KraSocketClientProtocolDest;
import earth.krakatao.protocol.KraSocketClientProtocolMessage; import earth.krakatao.protocol.KraSocketClientProtocolMessage;
import earth.krakatao.protocol.KraSocketClientProtocolStatus; import earth.krakatao.protocol.KraSocketClientProtocolStatus;
import java.net.URI; import java.net.URI;
@ -33,6 +34,10 @@ public class SocketClient extends WebSocketClient {
public void SendMessage(KraSocketClientProtocolMessage kraProtocolMessage) { public void SendMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
if (isOpen()) { if (isOpen()) {
if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()) {
this.kraProtocol.getSendQueueMessages()
.put(kraProtocolMessage.getCmdID(), kraProtocolMessage);
}
send(this.kraProtocol.EncodeMessage(kraProtocolMessage)); send(this.kraProtocol.EncodeMessage(kraProtocolMessage));
} }
} }