From 6506f5806fefb35059b53c3b52a1661cf811c225 Mon Sep 17 00:00:00 2001
From: "joy.zhou" <joy.zhou@ucloud.cn>
Date: Wed, 31 Jul 2019 16:22:05 +0800
Subject: [PATCH] fix bug

---
 broker/broker.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/broker/broker.go b/broker/broker.go
index 7e0125d..23b10a9 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -72,6 +72,7 @@ func NewBroker(config *Config) (*Broker, error) {
 		wpool:       pool.New(config.Worker),
 		nodes:       make(map[string]interface{}),
 		clusterPool: make(chan *Message),
+		rpcClient:   make(map[string]pb.HMQServiceClient),
 	}
 
 	var err error