Package org.apache.activemq.artemis.spi.core.protocol

Class MessagePersister

java.lang.Object

org.apache.activemq.artemis.spi.core.protocol.MessagePersister

All Implemented Interfaces:

org.apache.activemq.artemis.core.persistence.Persister<Message>

public class MessagePersister
extends Object
implements org.apache.activemq.artemis.core.persistence.Persister<Message>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MessagePersister()

Method Summary

Modifier and Type	Method	Description
static void	clearPersisters()
Message	decode(ActiveMQBuffer buffer, Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)
Message	decode(ActiveMQBuffer buffer, Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools, org.apache.activemq.artemis.core.persistence.StorageManager storageManager)
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 MessagePersister	getInstance()
static org.apache.activemq.artemis.core.persistence.Persister	getPersister(byte id)
static void	registerPersister(org.apache.activemq.artemis.core.persistence.Persister<Message> persister)
static void	registerProtocol(ProtocolManagerFactory manager)

Methods inherited from class java.lang.Object

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

Constructor Details

MessagePersister

protected MessagePersister()

Method Details

getID

public byte getID()

Description copied from interface: org.apache.activemq.artemis.core.persistence.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 org.apache.activemq.artemis.core.persistence.Persister<Message>

registerProtocol

public static void registerProtocol(ProtocolManagerFactory manager)

clearPersisters

public static void clearPersisters()

getPersister

public static org.apache.activemq.artemis.core.persistence.Persister getPersister(byte id)

registerPersister

public static void registerPersister(org.apache.activemq.artemis.core.persistence.Persister<Message> persister)

getInstance

public static MessagePersister getInstance()

getEncodeSize

public int getEncodeSize(Message record)

Specified by:

getEncodeSize in interface org.apache.activemq.artemis.core.persistence.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 org.apache.activemq.artemis.core.persistence.Persister<Message>

decode

public Message decode(ActiveMQBuffer buffer,
 Message record,
 org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)

Specified by:

decode in interface org.apache.activemq.artemis.core.persistence.Persister<Message>

decode

public Message decode(ActiveMQBuffer buffer,
 Message record,
 org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools,
 org.apache.activemq.artemis.core.persistence.StorageManager storageManager)