|
|
@@ -1,15 +1,14 @@
|
|
|
package nodes
|
|
|
|
|
|
import (
|
|
|
- "context"
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
|
MQTT "git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git"
|
|
|
"github.com/gogf/gf/util/guid"
|
|
|
"html/template"
|
|
|
- "sparrow/pkg/logger"
|
|
|
"sparrow/pkg/protocol"
|
|
|
"sparrow/pkg/ruleEngine"
|
|
|
+ "sparrow/pkg/server"
|
|
|
"strings"
|
|
|
"time"
|
|
|
)
|
|
|
@@ -60,7 +59,7 @@ func (M *MQTTBrokerNode) Init(ctx ruleEngine.Context, config string) error {
|
|
|
c := new(MQTTBrokerNodeCfg)
|
|
|
err := json.Unmarshal([]byte(config), c)
|
|
|
if err != nil {
|
|
|
- logger.Errorf(context.Background(), "初始化失败:%s", err.Error())
|
|
|
+ server.Log.Errorf("初始化失败：%s", err.Error())
|
|
|
return err
|
|
|
}
|
|
|
M.config = c
|
lijian