diff --git a/src/main/java/org/phoenixframework/channels/Socket.java b/src/main/java/org/phoenixframework/channels/Socket.java index 651e231..685d428 100755 --- 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; } -} \ No newline at end of file +}