From 1d8baa8c1797313037f3774e51bb43d2c3639a71 Mon Sep 17 00:00:00 2001
From: Joel Wetzell <git@jwetzell.com>
Date: Mon, 9 Feb 2026 23:17:53 -0600
Subject: [PATCH] add function to create new MQTTMessage

---
 internal/processor/mqtt-message-create.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/internal/processor/mqtt-message-create.go b/internal/processor/mqtt-message-create.go
index d416654..2227f8d 100644
--- a/internal/processor/mqtt-message-create.go
+++ b/internal/processor/mqtt-message-create.go
@@ -22,6 +22,15 @@ type MQTTMessageCreate struct {
 	Payload  []byte
 }
 
+func NewMQTTMessage(topic string, qos byte, retained bool, payload []byte) MQTTMessage {
+	return MQTTMessage{
+		topic:    topic,
+		qos:      qos,
+		retained: retained,
+		payload:  payload,
+	}
+}
+
 func (mm MQTTMessage) Duplicate() bool {
 	// TODO(jwetzell): implement?
 	return false