lz4-pure-java

wavefrontHQ · Sep 14, 2023 · bee889f · bee889f
1 parent 5e80b0c
commit bee889f
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 10 deletions.
diff --git a/proxy/pom.xml b/proxy/pom.xml
@@ -533,12 +533,12 @@
       <version>1.3.1</version>
       <scope>compile</scope>
     </dependency>
-    <dependency>
-      <groupId>net.jpountz.lz4</groupId>
-      <artifactId>lz4</artifactId>
-      <version>1.3.0</version>
-      <scope>compile</scope>
-    </dependency>
+      <dependency>
+          <groupId>org.lz4</groupId>
+          <artifactId>lz4-pure-java</artifactId>
+          <version>1.8.0</version>
+          <scope>runtime</scope>
+      </dependency>
     <dependency>
       <groupId>com.lmax</groupId>
       <artifactId>disruptor</artifactId>

diff --git a/proxy/src/main/java/com/wavefront/agent/queueing/RetryTaskConverter.java b/proxy/src/main/java/com/wavefront/agent/queueing/RetryTaskConverter.java
@@ -18,8 +18,8 @@
 import java.util.zip.GZIPOutputStream;
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
-import net.jpountz.lz4.LZ4BlockInputStream;
-import net.jpountz.lz4.LZ4BlockOutputStream;
+import org.apache.commons.compress.compressors.lz4.FramedLZ4CompressorInputStream;
+import org.apache.commons.compress.compressors.lz4.FramedLZ4CompressorOutputStream;
 import org.apache.commons.io.IOUtils;
 
 /**
@@ -72,7 +72,7 @@ public T fromBytes(@Nonnull byte[] bytes) {
           try {
             switch (compression) {
               case FORMAT_LZ4:
-                stream = new LZ4BlockInputStream(input);
+                stream = new FramedLZ4CompressorInputStream(input);
                 break;
               case FORMAT_GZIP:
                 stream = new GZIPInputStream(input);
@@ -116,7 +116,8 @@ public void serializeToStream(@Nonnull T t, @Nonnull OutputStream bytes) throws
       case LZ4:
         bytes.write(FORMAT_LZ4);
         bytes.write(ByteBuffer.allocate(4).putInt(t.weight()).array());
-        LZ4BlockOutputStream lz4BlockOutputStream = new LZ4BlockOutputStream(bytes);
+        FramedLZ4CompressorOutputStream lz4BlockOutputStream =
+            new FramedLZ4CompressorOutputStream(bytes);
         objectMapper.writeValue(lz4BlockOutputStream, t);
         lz4BlockOutputStream.close();
         return;