update logrus

pkg/server/config.go

@@ -22,7 +22,7 @@ const (
 )
 
 var (
-	confUDPHost = flag.String(FlagUDPHost, "", "udp server listen address, format ip:port")
+	confUDPHost = flag.String(FlagUDPHost, "", "udp server listen address, format ip:port ")
 	confTCPHost = flag.String(FlagTCPHost, "", "tcp server listen address, format ip:port")
 	confUseTls  = flag.Bool(FlagUseTls, false, "if tcp server uses tls, default false")
 

services/emqx-agent/client/mqtt_client.go

@@ -30,7 +30,7 @@ func NewMqttClient(conf *MqttConfig) (mcs *MqttClient, err error) {
 			var (
 				mc MQTT.Client
 			)
-			for i := 3; i > 0; i++ {
+			for i := 3; i > 0; i-- {
 				mc, err = initMqttClient(conf)
 				if err != nil {
 					server.Log.Errorf("init mqtt client failed: %s", err.Error())

services/emqx-agent/main.go

@@ -235,6 +235,7 @@ func main() {
 		User:     g.Cfg().GetString("mqtt.user"),
 		Password: g.Cfg().GetString("mqtt.password"),
 		Brokers:  g.Cfg().GetStrings("mqtt.brokers"),
+		ConnNum:  10,
 	})
 	if err != nil {
 		panic(err)

services/emqx-agent/sub_dev.go

@@ -41,11 +41,9 @@ type DevSubHandle interface {
 	Disconnected(status *protocol.DevConnectStatus) error
 }
 
-type (
-	MqttClient struct {
-		client *client.MqttClient
-	}
-)
+type MqttClient struct {
+	client *client.MqttClient
+}
 
 const (
 	ShareSubTopicPrefix = "$share/sparrow.agent/"