diff --git a/internal/manager/eventbus/mqtt_client.go b/internal/manager/eventbus/mqtt_client.go index 08dc0828..6b77a679 100644 --- a/internal/manager/eventbus/mqtt_client.go +++ b/internal/manager/eventbus/mqtt_client.go @@ -121,7 +121,7 @@ func (c *MQTTForwarder) Broadcast(topic EventTopic, payload interface{}) { logger := log.With(). Str("topic", fullTopic). - Interface("event", payload). + // Interface("event", payload). Logger() asJSON, err := json.Marshal(payload) diff --git a/internal/manager/eventbus/socketio.go b/internal/manager/eventbus/socketio.go index 0bdc3cfa..234972e1 100644 --- a/internal/manager/eventbus/socketio.go +++ b/internal/manager/eventbus/socketio.go @@ -62,7 +62,7 @@ func (s *SocketIOForwarder) Broadcast(topic EventTopic, payload interface{}) { log.Debug(). Str("topic", string(topic)). Str("eventType", eventType). - Interface("payload", payload). + // Interface("event", payload). Msg("socketIO: broadcasting message") s.sockserv.BroadcastTo(string(topic), eventType, payload) }