From 10687ec76ab3e3b80b2b156e87bef61794e20cc0 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Mon, 21 Jul 2025 21:11:13 +0000 Subject: [PATCH 1/2] Bump vertx.core.version from 4.5.14 to 5.0.1 Bumps `vertx.core.version` from 4.5.14 to 5.0.1. Updates `io.vertx:vertx-core` from 4.5.14 to 5.0.1 - [Commits](https://github.com/eclipse/vert.x/compare/4.5.14...5.0.1) Updates `io.vertx:vertx-codegen` from 4.5.14 to 5.0.1 --- updated-dependencies: - dependency-name: io.vertx:vertx-core dependency-version: 5.0.1 dependency-type: direct:production update-type: version-update:semver-major - dependency-name: io.vertx:vertx-codegen dependency-version: 5.0.1 dependency-type: direct:production update-type: version-update:semver-major ... Signed-off-by: dependabot[bot] --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index dc278d7d..d75ee440 100644 --- a/pom.xml +++ b/pom.xml @@ -105,7 +105,7 @@ 1.1.10.8 4.9.3 1.4.4 - 4.5.14 + 5.0.1 3.6.1 From e6abbaa595e521e03b3fb7f77bc498132806ead7 Mon Sep 17 00:00:00 2001 From: Brandon Arp Date: Mon, 21 Jul 2025 14:57:31 -0700 Subject: [PATCH 2/2] working tests --- pom.xml | 13 +++++++++++++ .../com/arpnetworking/tsdcore/sinks/VertxSink.java | 6 ++---- 2 files changed, 15 insertions(+), 4 deletions(-) diff --git a/pom.xml b/pom.xml index d75ee440..2ea0d104 100644 --- a/pom.xml +++ b/pom.xml @@ -535,6 +535,19 @@ + + + + + io.netty + netty-bom + 4.2.2.Final + pom + import + + + + diff --git a/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java b/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java index 36ec6795..325bf6ee 100644 --- a/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java +++ b/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java @@ -222,10 +222,8 @@ private void connectToServer() { .addData("port", _serverPort) .log(); _lastConnectionAttempt = currentTime; - _client.connect( - _serverPort, - resolvedHostname, - new ConnectionHandler(resolvedHostname)); + _client.connect(_serverPort, resolvedHostname) + .onComplete(new ConnectionHandler(resolvedHostname)); } private Handler createSocketCloseHandler(final NetSocket socket) {