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 {