diff --git a/gatherer/main.go b/gatherer/main.go
index 3a9e12d..38ccd26 100644
--- a/gatherer/main.go
+++ b/gatherer/main.go
@@ -52,10 +52,10 @@ func main() {
 
 	var forever chan struct{}
 
-	shellPipe := Piper{}
+	shellPipe := new(Piper)
 	shellPipe.Start(&influx, &amqpConn, "shelly", "shellies.#", ShellyConverter)
 
-	tasmotaPipe := Piper{}
+	tasmotaPipe := new(Piper)
 	tasmotaPipe.Start(&influx, &amqpConn, "tasmota", "tele.#.SENSOR", TasmotaConverter)
 
 	log.Printf(" [*] Waiting for logs. To exit press CTRL+C")