refactor: 服务接口 Stop() 重命名为 Shutdown()

mqtt.go

@@ -7,7 +7,7 @@ import (
 
 type MqttService interface {
 	Start() error
-	Stop() error
+	Shutdown() error
 	Restart() error
 
 	// 消息推送
@@ -33,9 +33,9 @@ type MqttService interface {
 type Mqtt interface {
 	Controller
 	// 链接
-	// OnConnect(g GlobalParams, topic string) error
+	OnConnect(g req.GlobalParams) error
 	// 断开链接
-	// OnDisconnect(g GlobalParams, topic string) error
+	OnDisconnect(g req.GlobalParams) error
 	// 订阅事件
 	OnSubscribed(g req.GlobalParams, topic string) error
 	// 取消订阅事件
@@ -60,6 +60,14 @@ type MqttHandle struct {
 	Controller
 }
 
+func (this *MqttHandle) OnConnect(g req.GlobalParams) error {
+	return ErrFuncNotImplemented
+}
+
+func (this *MqttHandle) OnDisconnect(g req.GlobalParams) error {
+	return ErrFuncNotImplemented
+}
+
 func (this *MqttHandle) OnSubscribed(g req.GlobalParams, topic string) error {
 	return ErrFuncNotImplemented
 }