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

added timer task for ack message handling

master
Alex 2022-02-26 20:27:46 +01:00
parent cb20cca48a
commit c94735a5d2
1 changed files with 2 additions and 3 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

@ -15,7 +15,7 @@ public class SocketClient extends WebSocketClient {
private final KraSocketClientProtocol kraProtocol;
private final KraSocketClientEventInitiater kraSocketClientEventInitiater;
private final TimerTask timerTask;
private TimerTask timerTask;
private Timer timer;
public SocketClient(URI serverUri, KraSocketClientEventInitiater kraSocketClientEventInitiater,
@ -24,8 +24,6 @@ public class SocketClient extends WebSocketClient {
this.kraSocketClientEventInitiater = kraSocketClientEventInitiater;
this.kraProtocol = kraProtocol;
this.timerTask = new KraSocketClientMessageTimerTask();
}
public void SendMessage(KraSocketClientProtocolMessage kraProtocolMessage) {
@ -44,6 +42,7 @@ public class SocketClient extends WebSocketClient {
this.kraSocketClientEventInitiater.callOnOpen(serverHandshake);
KraSocketClient.getLogger().info("connection opened");
this.timerTask = new KraSocketClientMessageTimerTask();
this.timer = new Timer(true);
this.timer.scheduleAtFixedRate(timerTask, 0, 3 * 1000);
}