From a8bca84c206f1e721f1f803e6767f42cdb041b6e Mon Sep 17 00:00:00 2001
From: liuqian <liuqian@followme-inc.com>
Date: Thu, 11 Oct 2018 18:15:35 +0800
Subject: [PATCH] add publish err for debug

---
 client.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/client.go b/client.go
index 89adb18..3a7a37e 100644
--- a/client.go
+++ b/client.go
@@ -69,13 +69,15 @@ func (c *Client) deleteConsumer(cons *Consumer) {
 }
 
 // Publish used to declare publishers
-func (c *Client) Publish(pub *Publisher) {
+func (c *Client) Publish(pub *Publisher) error {
 	c.l.Lock()
 	defer c.l.Unlock()
 	c.publishers[pub] = struct{}{}
-	if ch, err := c.channel(); err == nil {
+	ch, err := c.channel()
+	if err == nil {
 		go pub.serve(c, ch)
 	}
+	return err
 }
 
 func (c *Client) deletePublisher(pub *Publisher) {