From f135802a463bb6812350147be9cdee8b49f16c93 Mon Sep 17 00:00:00 2001 From: Nicolas Duhamel Date: Sun, 25 Dec 2022 21:53:58 +0100 Subject: [PATCH] Add dummy message object --- mqtt.go | 41 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 41 insertions(+) diff --git a/mqtt.go b/mqtt.go index 19c427a..c4102d1 100644 --- a/mqtt.go +++ b/mqtt.go @@ -19,6 +19,47 @@ type Message interface { Ack() } +type message struct { + duplicate bool + qos byte + retained bool + topic string + messageID uint16 + payload []byte + ack func() +} + +func (m *message) Duplicate() bool { + return m.duplicate +} + +func (m *message) Qos() byte { + return m.qos +} + +func (m *message) Retained() bool { + return m.retained +} + +func (m *message) Topic() string { + return m.topic +} + +func (m *message) MessageID() uint16 { + return m.messageID +} + +func (m *message) Payload() []byte { + return m.payload +} + +func (m *message) Ack() { +} + +func NewSimpleMessage(topic string, payload []byte, retained bool) *message { + return &message{topic: topic, payload: payload, retained: retained} +} + type Config struct { Host string Port string