Package org.apache.activemq.artemis.core.journal

Class EncoderPersister

java.lang.Object

org.apache.activemq.artemis.core.journal.EncoderPersister

All Implemented Interfaces:

Persister<EncodingSupport>

public class EncoderPersister
extends Object
implements Persister<EncodingSupport>

This is a facade between the new Persister and the former EncodingSupport. Methods using the old interface will use this as a facade to provide the previous semantic.

Method Summary

Modifier and Type	Method	Description
EncodingSupport	decode(ActiveMQBuffer buffer, EncodingSupport record, CoreMessageObjectPools pools)
void	encode(ActiveMQBuffer buffer, EncodingSupport record)
int	getEncodeSize(EncodingSupport record)
byte	getID()	This is to be used to store the protocol-id on Messages.
static EncoderPersister	getInstance()

Methods inherited from class java.lang.Object

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

Method Details

getID

public byte getID()

Description copied from interface: Persister

This is to be used to store the protocol-id on Messages. Messages are stored on their bare format. The protocol manager will be responsible to code or decode messages. The caveat here is that the first short-sized bytes need to be this constant.

Specified by:

getID in interface Persister<EncodingSupport>

getInstance

public static EncoderPersister getInstance()

getEncodeSize

public int getEncodeSize(EncodingSupport record)

Specified by:

getEncodeSize in interface Persister<EncodingSupport>

encode

public void encode(ActiveMQBuffer buffer,
 EncodingSupport record)

Specified by:

encode in interface Persister<EncodingSupport>

decode

public EncodingSupport decode(ActiveMQBuffer buffer,
 EncodingSupport record,
 CoreMessageObjectPools pools)

Specified by:

decode in interface Persister<EncodingSupport>