remove vertx dependency

Author: BrandonArp

pom.xml

@@ -118,6 +118,7 @@
     <guice.version>4.0</guice.version>
     <hamcrest.version>2.0.0.0</hamcrest.version>
     <hikari.version>2.5.1</hikari.version>
+    <asynchttpclient.version>2.0.11</asynchttpclient.version>
     <h2.version>1.4.190</h2.version>
     <jackson.version>2.8.5</jackson.version>
     <javassist.version>3.21.0-GA</javassist.version>
@@ -152,7 +153,6 @@
     <slf4j.version>1.7.22</slf4j.version>
     <signalfx.protoc.version>0.0.23</signalfx.protoc.version>
     <typesafe.config.version>1.3.1</typesafe.config.version>
-    <vertx.core.version>2.1.6</vertx.core.version>
     <wavefront.version>3.20</wavefront.version>
     <wiremock.version>1.57</wiremock.version>
 
@@ -715,30 +715,15 @@
       <version>${commons.codec.version}</version>
     </dependency>
     <dependency>
-      <groupId>io.netty</groupId>
-      <artifactId>netty-all</artifactId>
-      <version>${netty.all.version}</version>
-    </dependency>
-    <dependency>
-      <groupId>com.ning</groupId>
+      <groupId>org.asynchttpclient</groupId>
       <artifactId>async-http-client</artifactId>
-      <version>${ning.http.client.version}</version>
-    </dependency>
-    <dependency>
-      <groupId>com.typesafe.play</groupId>
-      <artifactId>play_${scala.version}</artifactId>
-      <version>${play.version}</version>
+      <version>${asynchttpclient.version}</version>
     </dependency>
     <dependency>
       <groupId>com.typesafe.play</groupId>
       <artifactId>play-java-ws_${scala.version}</artifactId>
       <version>${play.version}</version>
     </dependency>
-    <dependency>
-      <groupId>io.vertx</groupId>
-      <artifactId>vertx-core</artifactId>
-      <version>${vertx.core.version}</version>
-    </dependency>
     <dependency>
       <groupId>org.apache.httpcomponents</groupId>
       <artifactId>httpclient</artifactId>

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

@@ -17,14 +17,15 @@
 
 import akka.util.ByteIterator;
 import akka.util.ByteString;
+import akka.util.ByteStringBuilder;
 import com.arpnetworking.metrics.aggregation.protocol.Messages;
 import com.google.protobuf.GeneratedMessageV3;
 import com.google.protobuf.InvalidProtocolBufferException;
 import org.apache.commons.codec.binary.Hex;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.vertx.java.core.buffer.Buffer;
 
+import java.io.IOException;
 import java.nio.ByteOrder;
 import java.util.Optional;
 
@@ -132,27 +133,31 @@ private static boolean typeHasSubtype(final byte type) {
      *
      * @return <code>Buffer</code> containing serialized message.
      */
-    public Buffer serialize() {
-        final Buffer b = new Buffer();
-        b.appendInt(0);
+    public ByteString serialize() {
+        final ByteStringBuilder b = ByteString.createBuilder();
         if (_message instanceof Messages.HostIdentification) {
-            b.appendByte((byte) 0x01);
+            b.putByte((byte) 0x01);
         } else if (_message instanceof Messages.HeartbeatRecord) {
-            b.appendByte((byte) 0x03);
+            b.putByte((byte) 0x03);
         } else if (_message instanceof Messages.StatisticSetRecord) {
-            b.appendByte((byte) 0x04);
+            b.putByte((byte) 0x04);
         } else if (_message instanceof Messages.SamplesSupportingData) {
-            b.appendByte((byte) 0x05);
-            b.appendByte((byte) 0x01);
+            b.putByte((byte) 0x05);
+            b.putByte((byte) 0x01);
         } else if (_message instanceof Messages.SparseHistogramSupportingData) {
-            b.appendByte((byte) 0x05);
-            b.appendByte((byte) 0x02);
+            b.putByte((byte) 0x05);
+            b.putByte((byte) 0x02);
         } else {
             throw new IllegalArgumentException(String.format("Unsupported message; message=%s", _message));
         }
-        b.appendBytes(_message.toByteArray());
-        b.setInt(0, b.length());
-        return b;
+        try {
+            _message.writeTo(b.asOutputStream());
+        } catch (final IOException e) {
+            throw new RuntimeException(e);
+        }
+        final ByteStringBuilder sizePrefix = ByteString.createBuilder();
+        sizePrefix.putInt(b.length() + INTEGER_SIZE_IN_BYTES, ByteOrder.BIG_ENDIAN);
+        return sizePrefix.result().concat(b.result());
     }
 
     public GeneratedMessageV3 getMessage() {

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

@@ -17,6 +17,7 @@
 
 import akka.actor.Props;
 import akka.actor.UntypedActor;
+import akka.http.javadsl.model.StatusCodes;
 import akka.pattern.PatternsCS;
 import com.arpnetworking.logback.annotations.LogValue;
 import com.arpnetworking.steno.LogValueMapFactory;
@@ -26,7 +27,6 @@
 import com.google.common.base.Charsets;
 import com.google.common.collect.EvictingQueue;
 import com.google.common.collect.Sets;
-import io.netty.handler.codec.http.HttpResponseStatus;
 import org.asynchttpclient.AsyncCompletionHandler;
 import org.asynchttpclient.AsyncHttpClient;
 import org.asynchttpclient.Request;
@@ -291,10 +291,10 @@ public void postStop() throws Exception {
 
     static {
         // TODO(vkoskela): Make accepted status codes configurable [AINT-682]
-        ACCEPTED_STATUS_CODES.add(HttpResponseStatus.OK.code());
-        ACCEPTED_STATUS_CODES.add(HttpResponseStatus.CREATED.code());
-        ACCEPTED_STATUS_CODES.add(HttpResponseStatus.ACCEPTED.code());
-        ACCEPTED_STATUS_CODES.add(HttpResponseStatus.NO_CONTENT.code());
+        ACCEPTED_STATUS_CODES.add(StatusCodes.OK.intValue());
+        ACCEPTED_STATUS_CODES.add(StatusCodes.CREATED.intValue());
+        ACCEPTED_STATUS_CODES.add(StatusCodes.ACCEPTED.intValue());
+        ACCEPTED_STATUS_CODES.add(StatusCodes.NO_CONTENT.intValue());
     }
 
     /**