From a7082f0c4f3fa0d82d3bbf1f2fb67bc5b45e1977 Mon Sep 17 00:00:00 2001
From: Szc <sikkyzhao@gmail.com>
Date: Tue, 12 Feb 2019 20:58:03 -0800
Subject: [PATCH] Fix the bug that heartbeat ping not working properly

---
 sessions/ackqueue.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/sessions/ackqueue.go b/sessions/ackqueue.go
index ab6206c..a173676 100644
--- a/sessions/ackqueue.go
+++ b/sessions/ackqueue.go
@@ -126,8 +126,10 @@ func (this *Ackqueue) Wait(msg message.Message, onComplete interface{}) error {
 		this.ping = ackmsg{
 			Mtype:      message.PINGREQ,
 			State:      message.RESERVED,
+			Msgbuf : make([]byte,2),
 			OnComplete: onComplete,
 		}
+		msg.Encode(this.ping.Msgbuf)
 
 	default:
 		return errWaitMessage
@@ -165,6 +167,8 @@ func (this *Ackqueue) Ack(msg message.Message) error {
 	case message.PINGRESP:
 		if this.ping.Mtype == message.PINGREQ {
 			this.ping.State = message.PINGRESP
+			this.ping.Ackbuf = make([]byte,2)
+			msg.Encode(this.ping.Ackbuf)
 		}
 
 	default: