From 64000b23b74a2d040eba776161fd5ddf8111532a Mon Sep 17 00:00:00 2001 From: Alex Date: Sun, 27 Feb 2022 14:49:26 +0100 Subject: [PATCH] added timer task for ack message handling --- .../java/earth/krakatao/KraSocketClientMessageTimerTask.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/earth/krakatao/KraSocketClientMessageTimerTask.java b/src/main/java/earth/krakatao/KraSocketClientMessageTimerTask.java index 90f8a50..ffead19 100644 --- 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 consumer : this.socketClient.getKraProtocol() .getConsumerHashMap().values()) {