Package com.rabbitmq.stream.compression

Class CompressionUtils.ZstdJniCompressionCodec

java.lang.Object
com.rabbitmq.stream.compression.CompressionUtils.ZstdJniCompressionCodec
All Implemented Interfaces:
CompressionCodec
Enclosing class:
CompressionUtils
public static class CompressionUtils.ZstdJniCompressionCodec extends Object implements CompressionCodec

  • Constructor Details

    • ZstdJniCompressionCodec

      public ZstdJniCompressionCodec()

  • Method Details

    • maxCompressedLength

      public int maxCompressedLength(int sourceLength)
      Description copied from interface: CompressionCodec
      Provides the maximum compressed size from the source length.
      Specified by:
      maxCompressedLength in interface CompressionCodec
      Parameters:
      sourceLength - size of plain, uncompressed data
      Returns:
      maximum compressed size

    • compress

      public OutputStream compress(OutputStream outputStream)
      Description copied from interface: CompressionCodec
      Creates an OutputStream to compress data.
      Specified by:
      compress in interface CompressionCodec
      Parameters:
      outputStream - the stream where compressed data will end up
      Returns:
      output stream to write plain data to

    • decompress

      public InputStream decompress(InputStream inputStream)
      Description copied from interface: CompressionCodec
      Creates an InputStream to read decompressed data from.
      Specified by:
      decompress in interface CompressionCodec
      Parameters:
      inputStream - the stream to read compressed data from
      Returns:
      input stream to read decompressed data from

    • code

      public byte code()
      Description copied from interface: CompressionCodec
      Return the code for this type of codec.
      Specified by:
      code in interface CompressionCodec
      Returns:
      compression code

    • toString

      public String toString()
      Overrides:
      toString in class Object