MQTT Sensors #1
|
|
@ -202,9 +202,6 @@ func (s *MQTTBrokersService) EnsureListeners() {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: This needs to be refreshed when a new broker is added or a broker is updated
|
|
||||||
// TODO: Save all the coroutines and stop them when the server is stopped
|
|
||||||
|
|
||||||
s.MqttWaitGroup = &sync.WaitGroup{}
|
s.MqttWaitGroup = &sync.WaitGroup{}
|
||||||
|
|
||||||
for _, broker := range brokers {
|
for _, broker := range brokers {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue