Mqtt: add write timeout

therealtimex · Oct 8, 2024 · c5d3168 · c5d3168
1 parent a8df65f
commit c5d3168
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/provider/mqtt/client.go b/provider/mqtt/client.go
@@ -77,6 +77,7 @@ func NewClient(log *util.Logger, broker, user, password, clientID string, qos by
 	options.SetOnConnectHandler(mc.ConnectionHandler)
 	options.SetConnectionLostHandler(mc.ConnectionLostHandler)
 	options.SetConnectTimeout(request.Timeout)
+	options.SetWriteTimeout(request.Timeout)
 
 	tlsConfig := &tls.Config{
 		InsecureSkipVerify: insecure,