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

added WebsocketNotConnectedException handling

master
Alex 2022-03-13 20:18:18 +01:00
parent 9209c36586
commit de0b6332b7
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -11,6 +11,7 @@ import java.util.Timer;
import java.util.TimerTask; import java.util.TimerTask;
import lombok.Getter; import lombok.Getter;
import org.java_websocket.client.WebSocketClient; import org.java_websocket.client.WebSocketClient;
import org.java_websocket.exceptions.WebsocketNotConnectedException;
import org.java_websocket.handshake.ServerHandshake; import org.java_websocket.handshake.ServerHandshake;
public class SocketClient extends WebSocketClient { public class SocketClient extends WebSocketClient {
@ -32,12 +33,17 @@ public class SocketClient extends WebSocketClient {
} }
public void SendMessage(KraSocketClientProtocolMessage kraProtocolMessage) { public void SendMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
if (isOpen()) { try {
if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()) { if (isOpen()) {
this.kraProtocol.getSendQueueMessages() if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()) {
.put(kraProtocolMessage.getCmdID(), kraProtocolMessage); this.kraProtocol.getSendQueueMessages()
.put(kraProtocolMessage.getCmdID(), kraProtocolMessage);
}
send(this.kraProtocol.EncodeMessage(kraProtocolMessage));
} }
send(this.kraProtocol.EncodeMessage(kraProtocolMessage)); } catch (WebsocketNotConnectedException exception) {
KraSocketClient.getLogger().info("SendMessage error");
exception.printStackTrace();
} }
} }