From da639a40c812c27a44daaff3785f99d38854df3b Mon Sep 17 00:00:00 2001 From: Domenico Briganti Date: Sat, 20 Jun 2026 15:44:57 +0200 Subject: [PATCH] Server have to disconnect the client at least at keepalive * 1.5 (and increase the disconnection range from 500msec to 1 sec) (#301) --- .../mqtt/test/server/MqttServerNetworkIssueTest.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/test/java/io/vertx/mqtt/test/server/MqttServerNetworkIssueTest.java b/src/test/java/io/vertx/mqtt/test/server/MqttServerNetworkIssueTest.java index 28510a1a..6867ec35 100644 --- a/src/test/java/io/vertx/mqtt/test/server/MqttServerNetworkIssueTest.java +++ b/src/test/java/io/vertx/mqtt/test/server/MqttServerNetworkIssueTest.java @@ -110,10 +110,12 @@ public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { async.await(); + // the connection should be dropped within a 1 second window after the expected keep alive timeout long elapsed = ended - started; - // consider a range of 500 ms - context.assertTrue(elapsed > (timeout * 1000 - 500) && elapsed < (timeout * 1000 + 500), - elapsed + " > " + ((timeout * 1000 - 500)) + " && " + elapsed + " < " + (timeout * 1000 + 500) + " != true"); + long expectedMin = timeout * 1000L; + long expectedMax = expectedMin + 1000L; + context.assertTrue(elapsed >= expectedMin && elapsed <= expectedMax, + String.format("elapsed %d ms is not in the expected range [%d, %d] ms", elapsed, expectedMin, expectedMax)); } catch (MqttException e) { context.fail(e);