Package org.apache.activemq.artemis.core.message.impl

Class CoreMessagePersister

java.lang.Object

org.apache.activemq.artemis.core.message.impl.CoreMessagePersister

All Implemented Interfaces:

Persister<Message>

public class CoreMessagePersister
extends Object
implements Persister<Message>

Field Summary

Fields

Modifier and Type	Field	Description
static byte	ID

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CoreMessagePersister()

Method Summary

Modifier and Type	Method	Description
Message	decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pool)
void	encode(ActiveMQBuffer buffer, Message record)	Sub classes must add the first short as the protocol-id
int	getEncodeSize(Message record)
byte	getID()	This is to be used to store the protocol-id on Messages.
static CoreMessagePersister	getInstance()
static void	registerPersister(CoreMessagePersister newPersister)	This is a hook for testing
static void	resetPersister()

Methods inherited from class java.lang.Object

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

Field Detail

ID

public static final byte ID

See Also:

Constant Field Values

Constructor Detail

CoreMessagePersister

protected CoreMessagePersister()

Method Detail

registerPersister

public static void registerPersister(CoreMessagePersister newPersister)

This is a hook for testing

resetPersister

public static void resetPersister()

getInstance

public static CoreMessagePersister getInstance()

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

getEncodeSize

public int getEncodeSize(Message record)

Specified by:

getEncodeSize in interface Persister<Message>

encode

public void encode(ActiveMQBuffer buffer,
                   Message record)

Sub classes must add the first short as the protocol-id

Specified by:

encode in interface Persister<Message>

decode

public Message decode(ActiveMQBuffer buffer,
                      Message record,
                      CoreMessageObjectPools pool)

Specified by:

decode in interface Persister<Message>