Skip to content

Commit

Permalink
dev: remove unused log message
Browse files Browse the repository at this point in the history
  • Loading branch information
wwhai committed Jun 19, 2023
1 parent bd73f93 commit 577d525
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion plugin/mqtt_server/mqtt_server.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,8 @@ func (s *MqttServer) Init(config *ini.Section) error {

func (s *MqttServer) Start(r typex.RuleX) error {
s.ruleEngine = r
zlog := zerolog.New(glogger.GLogger.Writer())
zlog := zerolog.New(glogger.GLogger.Writer()).With().Logger()

server := mqtt.New(&mqtt.Options{Logger: &zlog})
tcp := listeners.NewTCP("node1", fmt.Sprintf("%v:%v", s.Host, s.Port), nil)
if err := server.AddListener(tcp); err != nil {
Expand Down

0 comments on commit 577d525

Please sign in to comment.