Class LargeMessagePersister
java.lang.Object
org.apache.activemq.artemis.core.persistence.impl.journal.codec.LargeMessagePersister
- All Implemented Interfaces:
Persister<LargeServerMessage>
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiondecode(ActiveMQBuffer buffer, LargeServerMessage message, CoreMessageObjectPools objectPools) voidencode(ActiveMQBuffer buffer, LargeServerMessage message) intgetEncodeSize(LargeServerMessage message) bytegetID()This is to be used to store the protocol-id on Messages.static LargeMessagePersister
-
Field Details
-
ID
public static final byte ID- See Also:
-
-
Constructor Details
-
LargeMessagePersister
protected LargeMessagePersister()
-
-
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.- Specified by:
getIDin interfacePersister<LargeServerMessage>
-
getInstance
-
decode
public LargeServerMessage decode(ActiveMQBuffer buffer, LargeServerMessage message, CoreMessageObjectPools objectPools) - Specified by:
decodein interfacePersister<LargeServerMessage>
-
encode
- Specified by:
encodein interfacePersister<LargeServerMessage>
-
getEncodeSize
- Specified by:
getEncodeSizein interfacePersister<LargeServerMessage>
-