added timer task for ack message handling

2022-02-27 14:49:26 +01:00 · 2022-02-27 14:49:26 +01:00 · 64000b23b7
parent 78a985147e
commit 64000b23b7
1 changed files with 3 additions and 1 deletions
--- a/src/main/java/earth/krakatao/KraSocketClientMessageTimerTask.java
+++ b/src/main/java/earth/krakatao/KraSocketClientMessageTimerTask.java
@ -14,7 +14,9 @@ public class KraSocketClientMessageTimerTask extends TimerTask {

  @Override
  public void run() {
-    KraSocketClient.getLogger().info("MessageTimerTask is running");
+    KraSocketClient.getLogger().info(
+        "MessageTimerTask is running " + this.socketClient.getKraProtocol().getConsumerHashMap()
+            .size());

    for (Consumer<KraSocketClientProtocolMessage> consumer : this.socketClient.getKraProtocol()
        .getConsumerHashMap().values()) {