Browse Source

Fix memory leak when Broker.Open and Broker.Close called repeatedly

darklore 5 năm trước cách đây
mục cha
commit
ca7391280e
1 tập tin đã thay đổi với 1 bổ sung0 xóa
  1. 1 0
      broker.go

+ 1 - 0
broker.go

@@ -1367,6 +1367,7 @@ func (b *Broker) unregisterMetrics() {
 	for _, name := range b.registeredMetrics {
 		b.conf.MetricRegistry.Unregister(name)
 	}
+	b.registeredMetrics = nil
 }
 
 func (b *Broker) registerMeter(name string) metrics.Meter {