diff --git a/collectors/collectorManager.go b/collectors/collectorManager.go index 4aae041..6140dbf 100644 --- a/collectors/collectorManager.go +++ b/collectors/collectorManager.go @@ -150,7 +150,10 @@ func (cm *collectorManager) AddOutput(output chan lp.CCMetric) { // Close finishes / stops the metric collector manager func (cm *collectorManager) Close() { - cm.done <- true + select { + case cm.done <- true: + default: + } cclog.ComponentDebug("CollectorManager", "CLOSE") }