From 76dccd6f0584599621e0ac0fc140a4a37b877f61 Mon Sep 17 00:00:00 2001
From: fengzhiqiang <fengzhq@it2000.com.cn>
Date: Tue, 8 Jan 2019 17:56:05 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BD=BF=E7=94=A8=E5=8D=95=E4=B8=80=E7=9A=84?=
 =?UTF-8?q?=E7=AD=89=E5=BE=85=E5=8F=82=E6=95=B0=20=E4=B8=8D=E8=AF=BB?=
 =?UTF-8?q?=E5=8F=96=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 serv.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/serv.go b/serv.go
index 55da298..5f72d48 100644
--- a/serv.go
+++ b/serv.go
@@ -30,7 +30,7 @@ const (
 	pingPeriod = (pongWait * 9) / 10
 
 	// Maximum message size allowed from peer.
-	maxMessageSize = 512
+	// maxMessageSize = 512
 )
 
 var (
@@ -90,7 +90,7 @@ func (c *Client) readPump() {
 		c.conn.Close()
 		log.WithField("client", c).Warn("exit")
 	}()
-	c.conn.SetReadLimit(maxMessageSize)
+	// c.conn.SetReadLimit(maxMessageSize)
 	c.conn.SetReadDeadline(time.Now().Add(pongWait))
 	c.conn.SetPongHandler(func(string) error { c.conn.SetReadDeadline(time.Now().Add(pongWait)); return nil })
 
@@ -231,8 +231,9 @@ func (h *Hub) read() {
 	for h.running == true {
 
 		if h.reader == nil {
+			log.Info("waiting ... ")
+			time.Sleep(writeWait)
 			h.reader = create(h.topic, h.offset)
-			time.Sleep(5 * time.Second)
 		}
 		m, err := h.reader.ReadMessage(context.Background())
 		if err != nil {