diff --git a/broker/broker.go b/broker/broker.go index 1a8b237..fc92415 100644 --- a/broker/broker.go +++ b/broker/broker.go @@ -328,7 +328,7 @@ func (b *Broker) handleConnection(typ int, conn net.Conn) { return } - log.Info("reconnect connect from ", zap.String("clientID", msg.ClientIdentifier)) + log.Info("read connect from ", zap.String("clientID", msg.ClientIdentifier)) connack := packets.NewControlPacket(packets.Connack).(*packets.ConnackPacket) connack.ReturnCode = packets.Accepted diff --git a/logger/logger.go b/logger/logger.go index b423a64..c55ac3a 100644 --- a/logger/logger.go +++ b/logger/logger.go @@ -16,6 +16,7 @@ var ( // NewDevLogger return a logger for dev builds func NewDevLogger() (*zap.Logger, error) { logCfg := zap.NewDevelopmentConfig() + // logCfg.Level = zap.NewAtomicLevelAt(zap.DebugLevel) logCfg.DisableStacktrace = true return logCfg.Build() } diff --git a/plugins/authhttp/authhttp.go b/plugins/authhttp/authhttp.go index cf488e5..d9a04e4 100644 --- a/plugins/authhttp/authhttp.go +++ b/plugins/authhttp/authhttp.go @@ -2,7 +2,6 @@ package authhttp import ( "encoding/json" - "fmt" "io/ioutil" "net/http" "net/url" @@ -44,7 +43,7 @@ func Init() { if err != nil { log.Fatal("Unmarshal config file error: ", zap.Error(err)) } - fmt.Println("http: config: ", config) + // fmt.Println("http: config: ", config) httpClient = &http.Client{ Transport: &http.Transport{