修改参数

mqtt_binding/mqtt_client/mqtt_client.go

@@ -15,9 +15,9 @@ type MqttClientOptions struct {
 	Password        string
 	Address         string
 	ClientID        string
-	KeepAliveSec    time.Duration
-	PingTimeoutSec  time.Duration
-	WriteTimeoutSec time.Duration
+	KeepAliveSec    int64
+	PingTimeoutSec  int64
+	WriteTimeoutSec int64
 }
 
 func (opt *MqttClientOptions) check() error {
@@ -68,9 +68,9 @@ func NewMqttClient(opts *MqttClientOptions) (*MqttClient, error) {
 		SetPassword(opts.Password).
 		AddBroker(opts.Address).
 		SetClientID(opts.ClientID).
-		SetKeepAlive(opts.KeepAliveSec*time.Second).
-		SetPingTimeout(opts.PingTimeoutSec*time.Second).
-		SetWriteTimeout(opts.WriteTimeoutSec*time.Second).
+		SetKeepAlive(time.Duration(opts.KeepAliveSec)*time.Second).
+		SetPingTimeout(time.Duration(opts.PingTimeoutSec)*time.Second).
+		SetWriteTimeout(time.Duration(opts.WriteTimeoutSec)*time.Second).
 		SetWill(opts.ClientID+"/will", "dead", 2, false).
 		SetOnConnectHandler(func(client mqtt.Client) {
 			err := mqttClient.onConnect()