services.moleculer.serializer

Class ChainedSerializer

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.serializer.Serializer

services.moleculer.serializer.ChainedSerializer

All Implemented Interfaces:

MoleculerLifecycle

Direct Known Subclasses:

BlockCipherSerializer, DeflaterSerializer

public abstract class ChainedSerializer
extends Serializer

Superclass of chainable Serializers. Sample of usage (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 Serializer	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

Modifier	Constructor and Description
protected	ChainedSerializer(Serializer parent)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getFormat()
void	setDebug(boolean debug)
void	started(ServiceBroker broker)
void	stopped()

Methods inherited from class services.moleculer.serializer.Serializer

isDebug, read, write

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

parent

protected final Serializer parent

Constructor Detail

ChainedSerializer

protected ChainedSerializer(Serializer parent)

Method Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class Serializer

Throws:

java.lang.Exception

stopped

public void stopped()

Specified by:

stopped in interface MoleculerLifecycle

Overrides:

stopped in class MoleculerComponent

getFormat

public java.lang.String getFormat()

Overrides:

getFormat in class Serializer

setDebug

public void setDebug(boolean debug)

Overrides:

setDebug in class Serializer