Merge pull request #2 from FastComments/subscriber-leak

Fix subscriber timer memory leak

Author: winrid

pubsub/src/main/java/com/fastcomments/pubsub/LiveEventSubscriber.java

@@ -131,6 +131,7 @@ private class FastCommentsWebSocketListener extends WebSocketListener {
         private final boolean[] isIntentionallyClosed;
         private final CommentWidgetConfig config;
         private final Timer pingTimer = new Timer();
+        private Timer reconnectTimer;
         private final String tenantId;
         private final String urlId;
         private final String userIdWS;
@@ -240,6 +241,12 @@ private void cleanup() {
             // Clean up ping timer
             pingTimer.cancel();
 
+            // Cancel any existing reconnect timer
+            if (reconnectTimer != null) {
+                reconnectTimer.cancel();
+                reconnectTimer = null;
+            }
+
             // Initialize last event time if not set
             if (lastEventTime <= 0) {
                 lastEventTime = new Date().getTime();
@@ -255,7 +262,8 @@ private void cleanup() {
                 double jitter = Math.random();
                 long reconnectDelay = (long) (RECONNECT_INTERVAL_BASE * jitter);
 
-                new Timer().schedule(new TimerTask() {
+                reconnectTimer = new Timer();
+                reconnectTimer.schedule(new TimerTask() {
                     @Override
                     public void run() {
                         if (!isIntentionallyClosed[0]) {