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