From a4f032b4967536d74b8a25181b478034f29c7169 Mon Sep 17 00:00:00 2001 From: what Date: Thu, 25 Apr 2024 21:51:08 +0800 Subject: [PATCH] =?UTF-8?q?[feat]=20=E6=96=B0=E5=A2=9E=20mqttt=20OnPublish?= =?UTF-8?q?=20hook?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mqtt.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/mqtt.go b/mqtt.go index b834709..456e282 100644 --- a/mqtt.go +++ b/mqtt.go @@ -75,6 +75,10 @@ func (this MqttHandle) OnMessageDropped(g GlobalParams, topic string, retain boo return ErrFuncNotImplemented } +func (this MqttHandle) OnPublish(g GlobalParams, topic string, retain bool, qos byte, raw []byte) ([]byte, error) { + return nil, ErrFuncNotImplemented +} + func NewMqttController(container *do.Injector) Mqtt { return &MqttHandle{ Controller: &BaseController{container},