Bump vertx-core from 2.1.6 to 4.4.2 (#292)

* Bump vertx-core from 2.1.6 to 4.4.2

Bumps [vertx-core](https://github.com/eclipse/vert.x) from 2.1.6 to 4.4.2.
- [Commits](eclipse-vertx/vert.x@v2.1.6...4.4.2)

---
updated-dependencies:
- dependency-name: io.vertx:vertx-core
  dependency-type: direct:production
  update-type: version-update:semver-major
...

Signed-off-by: dependabot[bot] <[email protected]>

* fixed build

---------

Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Brandon Arp <[email protected]>

Author: dependabot[bot]

pom.xml

@@ -105,7 +105,7 @@
     <snappy.version>1.1.9.1</snappy.version>
     <spotbugs.annotations.version>4.7.1</spotbugs.annotations.version>
     <typesafe.config.version>1.4.2</typesafe.config.version>
-    <vertx.core.version>2.1.6</vertx.core.version>
+    <vertx.core.version>4.4.2</vertx.core.version>
 
     <!--Test dependency versions-->
     <commons.math3.version>3.6.1</commons.math3.version>
@@ -791,6 +791,12 @@
         </exclusion>
       </exclusions>
     </dependency>
+    <dependency>
+      <groupId>io.vertx</groupId>
+      <artifactId>vertx-codegen</artifactId>
+      <version>${vertx.core.version}</version>
+      <scope>provided</scope>
+    </dependency>
     <dependency>
       <groupId>org.apache.httpcomponents</groupId>
       <artifactId>httpcore</artifactId>

src/main/java/com/arpnetworking/tsdcore/model/AggregationMessage.java

@@ -19,7 +19,7 @@
 import akka.util.ByteStringBuilder;
 import com.arpnetworking.metrics.aggregation.protocol.Messages;
 import com.google.protobuf.GeneratedMessageV3;
-import org.vertx.java.core.buffer.Buffer;
+import io.vertx.core.buffer.Buffer;
 
 import java.io.IOException;
 import java.nio.ByteOrder;
@@ -47,7 +47,7 @@ public static AggregationMessage create(final GeneratedMessageV3 message) {
      * @return ${code Buffer} containing serialized message.
      */
     public Buffer serializeToBuffer() {
-        final Buffer b = new Buffer();
+        final Buffer b = Buffer.buffer();
         b.appendInt(0);
         if (_message instanceof Messages.HostIdentification) {
             b.appendByte((byte) 0x01);

src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java

@@ -22,21 +22,18 @@
 import com.arpnetworking.utility.DefaultHostNameResolver;
 import com.arpnetworking.utility.HostNameResolver;
 import com.google.common.collect.EvictingQueue;
+import io.vertx.core.AsyncResult;
+import io.vertx.core.Context;
+import io.vertx.core.Handler;
+import io.vertx.core.Vertx;
+import io.vertx.core.buffer.Buffer;
+import io.vertx.core.net.NetClient;
+import io.vertx.core.net.NetClientOptions;
+import io.vertx.core.net.NetSocket;
 import net.sf.oval.constraint.Min;
 import net.sf.oval.constraint.NotEmpty;
 import net.sf.oval.constraint.NotNull;
 import net.sf.oval.constraint.Range;
-import org.vertx.java.core.AsyncResult;
-import org.vertx.java.core.AsyncResultHandler;
-import org.vertx.java.core.Context;
-import org.vertx.java.core.Handler;
-import org.vertx.java.core.Vertx;
-import org.vertx.java.core.VertxFactory;
-import org.vertx.java.core.buffer.Buffer;
-import org.vertx.java.core.impl.DefaultContext;
-import org.vertx.java.core.impl.DefaultVertx;
-import org.vertx.java.core.net.NetClient;
-import org.vertx.java.core.net.NetSocket;
 
 import java.time.Duration;
 import java.time.ZonedDateTime;
@@ -342,26 +339,15 @@ protected VertxSink(final Builder<?, ?> builder) {
         _serverAddress = builder._serverAddress;
         _hostnameResolver = builder._hostnameResolver;
         _serverPort = builder._serverPort;
-        _vertx = VertxFactory.newVertx();
-        //Calling this just so the context gets created
-        if (_vertx instanceof DefaultVertx) {
-            final DefaultVertx vertx = (DefaultVertx) _vertx;
-            final DefaultContext context = vertx.getOrCreateContext();
-            vertx.setContext(context);
-            _context = context;
-        } else {
-            _context = null;
-            LOGGER.warn()
-                    .setMessage("Vertx instance not a DefaultVertx as expected. Threading may be incorrect.")
-                    .addData("sink", getName())
-                    .log();
-        }
-
-        _client = _vertx.createNetClient()
-                .setReconnectAttempts(0)
-                .setConnectTimeout(5000)
-                .setTCPNoDelay(true)
-                .setTCPKeepAlive(true);
+        _vertx = Vertx.vertx();
+        _context = _vertx.getOrCreateContext();
+
+        _client = _vertx.createNetClient(
+                new NetClientOptions()
+                        .setReconnectAttempts(0)
+                        .setConnectTimeout(5000)
+                        .setTcpNoDelay(true)
+                        .setTcpKeepAlive(true));
         _socket = new AtomicReference<>();
         _pendingData = EvictingQueue.create(builder._maxQueueSize);
         _exponentialBackoffBase = builder._exponentialBackoffBase;
@@ -390,7 +376,7 @@ protected VertxSink(final Builder<?, ?> builder) {
     private static final long MAX_FLUSH_BYTES = 2 ^ 20; // 1 Mebibyte
     private static final int NO_DATA_CONSUME_LOOP_INTERVAL = 100;
 
-    private class ConnectionHandler implements AsyncResultHandler<NetSocket> {
+    private class ConnectionHandler implements Handler<AsyncResult<NetSocket>> {
 
         @Override
         public void handle(final AsyncResult<NetSocket> event) {

src/test/java/com/arpnetworking/tsdcore/model/AggregationMessageTest.java

@@ -19,10 +19,10 @@
 import com.arpnetworking.metrics.aggregation.protocol.Messages;
 import com.google.protobuf.GeneratedMessageV3;
 import com.google.protobuf.UnknownFieldSet;
+import io.vertx.core.buffer.Buffer;
 import org.junit.Assert;
 import org.junit.Test;
 import org.mockito.Mockito;
-import org.vertx.java.core.buffer.Buffer;
 
 import java.nio.ByteOrder;