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

ronanh · Mar 4, 2020 · 3f01cdd · 3f01cdd
1 parent 29035d4
commit 3f01cdd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/broker.go b/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 {