fix(confmws/confmqtt): fix NewClient, try fetch client by id from cache

xoctopus · Jul 19, 2024 · 7ebbcbc · 7ebbcbc
1 parent fbe6bce
commit 7ebbcbc
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/confmws/confmqtt/broker.go b/confmws/confmqtt/broker.go
@@ -135,6 +135,10 @@ func (b *Broker) NewClient(id, topic string) (*Client, error) {
 	if topic == "" {
 		return nil, ErrInvalidTopic
 	}
+	if c, ok := b.clients.Load(id); ok && c != nil {
+		return c.(*Client), nil
+	}
+
 	option := b.options(id)
 
 	c := &Client{