Class MessagePersister
java.lang.Object
org.apache.activemq.artemis.spi.core.protocol.MessagePersister
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic voiddecode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools) decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager) voidencode(ActiveMQBuffer buffer, Message record) Sub classes must add the first short as the protocol-idintgetEncodeSize(Message record) bytegetID()This is to be used to store the protocol-id on Messages.static MessagePersisterstatic PersistergetPersister(byte id) static voidregisterPersister(Persister<Message> persister) static voidregisterProtocol(ProtocolManagerFactory manager)
-
Constructor Details
-
MessagePersister
protected MessagePersister()
-
-
Method Details
-
getID
public byte getID()Description copied from interface:PersisterThis 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. -
registerProtocol
-
clearPersisters
public static void clearPersisters() -
getPersister
-
registerPersister
-
getInstance
-
getEncodeSize
- Specified by:
getEncodeSizein interfacePersister<Message>
-
encode
Sub classes must add the first short as the protocol-id -
decode
-
decode
public Message decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager)
-