Package org.apache.activemq.artemis.core.persistence.impl.journal.codec

Class LargeMessagePersister

java.lang.Object

org.apache.activemq.artemis.core.persistence.impl.journal.codec.LargeMessagePersister

All Implemented Interfaces:

Persister<LargeServerMessage>

public class LargeMessagePersister
extends Object
implements Persister<LargeServerMessage>

Field Summary

Fields

Modifier and Type	Field	Description
static final byte	ID

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LargeMessagePersister()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

ID

public static final byte ID

See Also:

• Constant Field Values

Constructor Details

LargeMessagePersister

protected LargeMessagePersister()

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<LargeServerMessage>

getInstance

public static LargeMessagePersister getInstance()

decode

public LargeServerMessage decode(ActiveMQBuffer buffer,
 LargeServerMessage message,
 CoreMessageObjectPools objectPools)

Specified by:

decode in interface Persister<LargeServerMessage>

encode

public void encode(ActiveMQBuffer buffer,
 LargeServerMessage message)

Specified by:

encode in interface Persister<LargeServerMessage>

getEncodeSize

public int getEncodeSize(LargeServerMessage message)

Specified by:

getEncodeSize in interface Persister<LargeServerMessage>