Browse Source

update MQTT configuration and increase connection timeouts

jx-test
修宁 5 months ago
parent
commit
16db63036a
  1. 4
      servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java
  2. 4
      servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java

4
servo/src/main/java/com/galaxis/rcs/ptr/PtrMqttClient.java

@ -39,9 +39,9 @@ public class PtrMqttClient implements MqttCallback {
options.setAutomaticReconnect(true); options.setAutomaticReconnect(true);
options.setUserName(username); options.setUserName(username);
options.setPassword(password.getBytes()); options.setPassword(password.getBytes());
options.setConnectionTimeout(1); options.setConnectionTimeout(5000);
options.setKeepAliveInterval(20); options.setKeepAliveInterval(20);
options.setExecutorServiceTimeout(1); options.setExecutorServiceTimeout(5000);
client.setCallback(this); client.setCallback(this);
client.connect(options); client.connect(options);

4
servo/src/main/java/com/yvan/pusher/FrontendMessagePushService.java

@ -76,9 +76,9 @@ public class FrontendMessagePushService implements MqttCallback {
options.setUserName(mqttConfig.getUsername()); options.setUserName(mqttConfig.getUsername());
options.setPassword(mqttConfig.getPassword().getBytes()); options.setPassword(mqttConfig.getPassword().getBytes());
options.setAutomaticReconnect(true); options.setAutomaticReconnect(true);
options.setConnectionTimeout(10); options.setConnectionTimeout(5000);
options.setKeepAliveInterval(60); options.setKeepAliveInterval(60);
options.setExecutorServiceTimeout(1); options.setExecutorServiceTimeout(5000);
// 尝试连接 // 尝试连接
int attempts = 0; int attempts = 0;

Loading…
Cancel
Save