racecar_analytics mqtt subscription functions

main.go

func SubscribeECU() {
	Client.Subscribe("ingest/ecu", 0, func(client mqtt.Client, msg mqtt.Message) {
		fmt.Println("[MQ] Received ecu message")
	})
}

func SubscribeBattery() {
	Client.Subscribe("ingest/battery", 0, func(client mqtt.Client, msg mqtt.Message) {
		fmt.Println("[MQ] Received battery message")
	})
}