From c94735a5d27bd11e66215aaa07de26c291de472f Mon Sep 17 00:00:00 2001
From: Alex <alex@roese.dev>
Date: Sat, 26 Feb 2022 20:27:46 +0100
Subject: [PATCH] added timer task for ack message handling

---
 src/main/java/earth/krakatao/SocketClient.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/java/earth/krakatao/SocketClient.java b/src/main/java/earth/krakatao/SocketClient.java
index 1a3e207..14b79ae 100644
--- a/src/main/java/earth/krakatao/SocketClient.java
+++ b/src/main/java/earth/krakatao/SocketClient.java
@@ -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);
   }