services.moleculer.serializer

Class DeflaterSerializer

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.serializer.Serializer

services.moleculer.serializer.ChainedSerializer

services.moleculer.serializer.DeflaterSerializer

All Implemented Interfaces:

MoleculerLifecycle

public class DeflaterSerializer
extends ChainedSerializer

Message compressor / decompressor. Sample of usage:

 Transporter trans = new NatsTransporter("localhost");
 trans.setSerializer(new DeflaterSerializer());
 ServiceBroker broker = ServiceBroker.builder().nodeID("node1").transporter(trans).build();
 

Chaining Serializers (serialize then compress then encrypt packets):

 Transporter trans = new NatsTransporter("localhost");
 MsgPackSerializer msgPack = new MsgPackSerializer();
 DeflaterSerializer deflater = new DeflaterSerializer(msgPack);
 BlockCipherSerializer cipher = new BlockCipherSerializer(deflater);
 trans.setSerializer(cipher);
 

Field Summary

Fields

Modifier and Type	Field and Description
protected int	compressionLevel Compression level (best speed = 1, best compression = 9)
protected int	threshold Compress key and/or value above this size (BYTES), 0 = disable compression

Fields inherited from class services.moleculer.serializer.ChainedSerializer

parent

Fields inherited from class services.moleculer.serializer.Serializer

debug, format, reader, writer

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
DeflaterSerializer() Creates a JSON-based Serializer that compresses content above 1024 bytes with compression level "1".
DeflaterSerializer(int threshold) Creates a JSON-based Serializer that compresses content above a specified size (see the "compressAbove" parameter).
DeflaterSerializer(int threshold, int compressionLevel) Creates a JSON-based Serializer that compresses content above a specified size with the specified compression level (1-9).
DeflaterSerializer(Serializer parent) Creates a custom Serializer that compresses content above 1024 bytes size with the compression level "1".
DeflaterSerializer(Serializer parent, int threshold, int compressionLevel) Creates a custom Serializer that compresses content above a specified size with the specified compression level (1-9).

Method Summary

Modifier and Type	Method and Description
int	getCompressionLevel()
int	getThreshold()
io.datatree.Tree	read(byte[] source)
void	setCompressionLevel(int compressionLevel)
void	setThreshold(int threshold)
byte[]	write(io.datatree.Tree value)

Methods inherited from class services.moleculer.serializer.ChainedSerializer

getFormat, setDebug, started, stopped

Methods inherited from class services.moleculer.serializer.Serializer

isDebug

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

threshold

protected int threshold

Compress key and/or value above this size (BYTES), 0 = disable compression

compressionLevel

protected int compressionLevel

Compression level (best speed = 1, best compression = 9)

Constructor Detail

DeflaterSerializer

public DeflaterSerializer()

Creates a JSON-based Serializer that compresses content above 1024 bytes with compression level "1".

DeflaterSerializer

public DeflaterSerializer(int threshold)

Creates a JSON-based Serializer that compresses content above a specified size (see the "compressAbove" parameter).

Parameters:

threshold - Compress key and/or value above this size (BYTES), 0 = disable compression

DeflaterSerializer

public DeflaterSerializer(int threshold,
                          int compressionLevel)

Creates a JSON-based Serializer that compresses content above a specified size with the specified compression level (1-9).

Parameters:

threshold - Compress key and/or value above this size (BYTES), 0 = disable compression

compressionLevel - Compression level (best speed = 1, best compression = 9)

DeflaterSerializer

public DeflaterSerializer(Serializer parent)

Creates a custom Serializer that compresses content above 1024 bytes size with the compression level "1".

Parameters:

parent - parent Serializer (eg. a JsonSerializer)

DeflaterSerializer

public DeflaterSerializer(Serializer parent,
                          int threshold,
                          int compressionLevel)

Creates a custom Serializer that compresses content above a specified size with the specified compression level (1-9).

Parameters:

parent - parent Serializer (eg. a JsonSerializer)

threshold - Compress key and/or value above this size (BYTES), 0 = disable compression

compressionLevel - Compression level (best speed = 1, best compression = 9)

Method Detail

write

public byte[] write(io.datatree.Tree value)
             throws java.lang.Exception

Overrides:

write in class Serializer

Throws:

java.lang.Exception

read

public io.datatree.Tree read(byte[] source)
                      throws java.lang.Exception

Overrides:

read in class Serializer

Throws:

java.lang.Exception

getCompressionLevel

public int getCompressionLevel()

setCompressionLevel

public void setCompressionLevel(int compressionLevel)

getThreshold

public int getThreshold()

setThreshold

public void setThreshold(int threshold)