fix: use max session expiry sec supported by AWS IoT Core (#1646)

aws-greengrass · Jul 23, 2024 · f72ad92 · f72ad92
1 parent 865be65
commit f72ad92
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/aws/greengrass/mqttclient/AwsIotMqtt5Client.java b/src/main/java/com/aws/greengrass/mqttclient/AwsIotMqtt5Client.java
@@ -72,6 +72,7 @@ class AwsIotMqtt5Client implements IndividualMqttClient {
 
     static final String TOPIC_KEY = "topic";
     private static final String RESUB_LOG_EVENT = "resubscribe";
+    private static final long DEFAULT_SESSION_EXPIRY_SECONDS = 604_800L; // Maximum time supported by AWS IoT Core
     private final Provider<AwsIotMqtt5ClientBuilder> builderProvider;
 
     private Mqtt5Client client = null;
@@ -346,7 +347,7 @@ private void internalConnect() {
                                         .withReceiveMaximum(Coerce.toLong(mqttTopics.findOrDefault(100L,
                                                 "receiveMaximum")))
                                         .withSessionExpiryIntervalSeconds(
-                                                Coerce.toLong(mqttTopics.findOrDefault(10_080L,
+                                                Coerce.toLong(mqttTopics.findOrDefault(DEFAULT_SESSION_EXPIRY_SECONDS,
                                                         "sessionExpirySeconds"))));
                 client = builder.build();
             } catch (MqttException e) {