Interface Persister<T>

All Known Implementing Classes:
AbstractHashMapPersister, AckRetry.Persister, CoreMessagePersister, EncoderPersister, LargeMessagePersister, MessagePersister

public interface Persister<T>
  • Method Details

    • getID

      byte getID()
      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.
    • getEncodeSize

      int getEncodeSize(T record)
    • encode

      void encode(ActiveMQBuffer buffer, T record)
    • decode

      T decode(ActiveMQBuffer buffer, T record, CoreMessageObjectPools pool)