Class DefaultCompressionCodecFactory

java.lang.Object

com.rabbitmq.stream.compression.DefaultCompressionCodecFactory

All Implemented Interfaces:

CompressionCodecFactory

public class DefaultCompressionCodecFactory
extends Object
implements CompressionCodecFactory

CompressionCodecFactory implementation using various compression libraries.

The GZIP codec is based on the JDK implementation, the SNAPPY codec uses Xerial Snappy (framed), the LZ4 codec uses LZ4 Java (framed), the ZSTD codec uses zstd-jni. This factory gracefully handles missing native libraries. If a native compression library is not available (e.g., on Android or when dependencies are excluded), the corresponding codec will be unavailable and requesting it will throw a CompressionException. gzip is always available since it is a part of the JDK.

See Also:

• PortableCompressionCodecFactory

Constructor Summary

Constructors

Constructor	Description
DefaultCompressionCodecFactory()

Method Summary

Modifier and Type	Method	Description
CompressionCodec	get(Compression compression)	Get a compression codec for a given type of compression.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultCompressionCodecFactory

public DefaultCompressionCodecFactory()

Method Details

get

public CompressionCodec get(Compression compression)

Description copied from interface: CompressionCodecFactory

Get a compression codec for a given type of compression.

Specified by:

get in interface CompressionCodecFactory

Parameters:

compression - the type of compression codec

Returns:

the appropriate compression codec