diff --git a/src/test/java/io/vertx/mqtt/test/client/MqttClientKeepAliveTest.java b/src/test/java/io/vertx/mqtt/test/client/MqttClientKeepAliveTest.java index 180940ed..5fa71b1b 100644 --- a/src/test/java/io/vertx/mqtt/test/client/MqttClientKeepAliveTest.java +++ b/src/test/java/io/vertx/mqtt/test/client/MqttClientKeepAliveTest.java @@ -47,7 +47,7 @@ public class MqttClientKeepAliveTest { private void startServer(TestContext ctx) { Async async = ctx.async(); - server.listen(1884, "localhost", ctx.asyncAssertSuccess(server -> async.complete())); + server.listen(1885, "localhost", ctx.asyncAssertSuccess(server -> async.complete())); async.awaitSuccess(10000); } diff --git a/src/test/java/io/vertx/mqtt/test/server/MqttServerKeepAliveTest.java b/src/test/java/io/vertx/mqtt/test/server/MqttServerKeepAliveTest.java index 1bac804f..c973af51 100644 --- a/src/test/java/io/vertx/mqtt/test/server/MqttServerKeepAliveTest.java +++ b/src/test/java/io/vertx/mqtt/test/server/MqttServerKeepAliveTest.java @@ -43,7 +43,7 @@ public class MqttServerKeepAliveTest { private void startServer(TestContext ctx) { Async async = ctx.async(); - server.listen(1884, "localhost", ctx.asyncAssertSuccess(server -> async.complete())); + server.listen(1885, "localhost", ctx.asyncAssertSuccess(server -> async.complete())); async.awaitSuccess(10000); }