Add MQTTMessage.String()

This simplifies debugging.

1 files changed, 4 insertions, 0 deletions

diff --git a/mqtt.go b/mqtt.go
index a7b374d..d9f0632 100644
--- a/mqtt.go
+++ b/mqtt.go
@@ -25,6 +25,10 @@ type MQTTMessage struct {
 	Payload []byte
 }
 
+func (m MQTTMessage) String() string {
+	return fmt.Sprintf("topic='%s' message='%s'", m.Topic, string(m.Payload))
+}
+
 func MQTTRun(config MQTTConfig, tx chan MQTTMessage) {
 	mqttServerHealthTopic = fmt.Sprintf("%s/server/health", config.TopicPrefix)