Class EncoderPersister
java.lang.Object
org.apache.activemq.artemis.core.journal.EncoderPersister
- All Implemented Interfaces:
Persister<EncodingSupport>
This is a facade between the new Persister and the former EncodingSupport. Methods using the old interface will use
this as a facade to provide the previous semantic.
-
Method Summary
Modifier and TypeMethodDescriptiondecode(ActiveMQBuffer buffer, EncodingSupport record, CoreMessageObjectPools pools) voidencode(ActiveMQBuffer buffer, EncodingSupport record) intgetEncodeSize(EncodingSupport record) bytegetID()This is to be used to store the protocol-id on Messages.static EncoderPersister
-
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<EncodingSupport>
-
getInstance
-
getEncodeSize
- Specified by:
getEncodeSizein interfacePersister<EncodingSupport>
-
encode
- Specified by:
encodein interfacePersister<EncodingSupport>
-
decode
public EncodingSupport decode(ActiveMQBuffer buffer, EncodingSupport record, CoreMessageObjectPools pools) - Specified by:
decodein interfacePersister<EncodingSupport>
-