diff --git a/consumer/influx_stat.go b/consumer/influx_stat.go
index 8895c9f..2d7e1d3 100644
--- a/consumer/influx_stat.go
+++ b/consumer/influx_stat.go
@@ -9,7 +9,7 @@ import (
 )
 
 var (
-	influxLogger = logger.NewLogger("consumer")
+	influxLogger = logger.NewLogger("influx")
 )
 
 type influxMetric struct {
diff --git a/main.go b/main.go
index 19fd466..8247e0b 100644
--- a/main.go
+++ b/main.go
@@ -120,9 +120,6 @@ func main() {
 		tempetureChannel = make(chan processor.TempetureInfo)
 		fanspeedChannel  = make(chan processor.FanspeedInfo)
 	)
-	defer close(tempetureChannel)
-	defer close(fanspeedChannel)
-
 	processors = make([]processor.Processor, 0, processorCount)
 	for i := 0; i < processorCount; i++ {
 		if info, err := processor.NewProcessorInfo(handler, i, sampleDuration,
@@ -141,10 +138,15 @@ func main() {
 	fanController := consumer.NewFanControl(processorCount, sampleDuration, handler)
 	metricLogger := consumer.NewInfluxMetric("", processorCount, handler)
 
+
 	handler.IncreaseWait()
 	go FanoutTempeture(tempetureChannel, handler, metricLogger.TempetureConsumer())
+	defer close(tempetureChannel)
+
 	handler.IncreaseWait()
 	go FanoutSpeed(fanspeedChannel, handler, fanController.Consumer(), metricLogger.FanSpeedConsumer())
+	defer close(fanspeedChannel)
+
 	handler.IncreaseWait()
 	go fanController.StartControl()
 	handler.IncreaseWait()