fix bug

2026-08-30 22:34:52 +00:00 · 2019-07-31 16:22:05 +08:00
parent 18e9a1dd04
commit 6506f5806f
1 changed files with 1 additions and 0 deletions
@@ -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