Apply minimum mqtt timeout constraint and inform client of updated ti…

…meout if too low (#1180)
aklivity · Aug 5, 2024 · 1dbc46b · 1dbc46b
1 parent c344036
commit 1dbc46b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java b/...c/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java
@@ -2883,7 +2883,7 @@ private int onDecodeConnect(
 
             this.keepAlive = (short) Math.min(Math.max(keepAlive, keepAliveMinimum), keepAliveMaximum);
             serverDefinedKeepAlive = this.keepAlive != keepAlive;
-            keepAliveTimeout = Math.round(TimeUnit.SECONDS.toMillis(keepAlive) * 1.5);
+            keepAliveTimeout = Math.round(TimeUnit.SECONDS.toMillis(this.keepAlive) * 1.5);
             connectFlags = flags;
             version = protocolVersion;
             doSignalKeepAliveTimeout(traceId);