Skip to content

Commit

Permalink
Apply minimum mqtt timeout constraint and inform client of updated ti…
Browse files Browse the repository at this point in the history
…meout if too low
  • Loading branch information
jfallows committed Aug 4, 2024
1 parent 153aac1 commit d65cf66
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit d65cf66

Please sign in to comment.