[feat] 新增 mqttt OnPublish hook

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},