From 91d15df765b789d6ee5937797ce39271c81c0f14 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Sun, 4 Feb 2024 17:03:38 +0100 Subject: [PATCH] Manager Cleanup: consistent variable name for MQTTClient receiver pointer No functional changes. --- internal/manager/eventbus/mqtt_client.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/manager/eventbus/mqtt_client.go b/internal/manager/eventbus/mqtt_client.go index ea62333d..ad7d64ee 100644 --- a/internal/manager/eventbus/mqtt_client.go +++ b/internal/manager/eventbus/mqtt_client.go @@ -116,8 +116,8 @@ func (m *MQTTForwarder) onServerDisconnect(d *paho.Disconnect) { logEntry.Msg("mqtt client: server requested disconnect") } -func (c *MQTTForwarder) Broadcast(topic EventTopic, payload interface{}) { - fullTopic := c.topicPrefix + string(topic) +func (m *MQTTForwarder) Broadcast(topic EventTopic, payload interface{}) { + fullTopic := m.topicPrefix + string(topic) logger := log.With(). Str("topic", fullTopic). @@ -134,7 +134,7 @@ func (c *MQTTForwarder) Broadcast(topic EventTopic, payload interface{}) { // Publish will block so we run it in a GoRoutine. // TODO: might be a good idea todo this at the event broker level, rather than in this function. go func(topic string, msg []byte) { - pr, err := c.conn.Publish(c.ctx, &paho.Publish{ + pr, err := m.conn.Publish(m.ctx, &paho.Publish{ QoS: mqttQoS, Topic: topic, Payload: msg,