From 16db63036a440d2adda17a3edbb6c041d4defcd4 Mon Sep 17 00:00:00 2001 From: luoyifan Date: Tue, 22 Jul 2025 15:39:54 +0800 Subject: [PATCH] update MQTT configuration and increase connection timeouts --- servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java | 4 ++-- servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java b/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java index 66aae6f..7c6e379 100644 --- a/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java +++ b/servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java @@ -39,9 +39,9 @@ public class PtrMqttClient implements MqttCallback { options.setAutomaticReconnect(true); options.setUserName(username); options.setPassword(password.getBytes()); - options.setConnectionTimeout(1); + options.setConnectionTimeout(5000); options.setKeepAliveInterval(20); - options.setExecutorServiceTimeout(1); + options.setExecutorServiceTimeout(5000); client.setCallback(this); client.connect(options); diff --git a/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java b/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java index 90a3532..2f84bc3 100644 --- a/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java +++ b/servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java @@ -76,9 +76,9 @@ public class FrontendMessagePushService implements MqttCallback { options.setUserName(mqttConfig.getUsername()); options.setPassword(mqttConfig.getPassword().getBytes()); options.setAutomaticReconnect(true); - options.setConnectionTimeout(10); + options.setConnectionTimeout(5000); options.setKeepAliveInterval(60); - options.setExecutorServiceTimeout(1); + options.setExecutorServiceTimeout(5000); // 尝试连接 int attempts = 0;