fixed heartbeat inteval timer.

Was called only one
myhobnob · Jan 21, 2016 · 0a0e190 · 0a0e190
1 parent 70e24ad
commit 0a0e190
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/org/phoenixframework/channels/Socket.java b/src/main/java/org/phoenixframework/channels/Socket.java
@@ -156,7 +156,7 @@ public void run() {
             }
         };
 
-        timer.schedule(Socket.this.heartbeatTimerTask, Socket.this.heartbeatInterval);
+        timer.schedule(Socket.this.heartbeatTimerTask, Socket.this.heartbeatInterval, Socket.this.heartbeatInterval);
     }
 
     private void cancelHeartbeatTimer(){
@@ -380,4 +380,4 @@ private void flushSendBuffer() {
     static String replyEventName(final String ref) {
         return "chan_reply_" + ref;
     }
-}
+}