Add dummy message object

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