Class MessagePersister

java.lang.Object
org.apache.activemq.artemis.spi.core.protocol.MessagePersister
All Implemented Interfaces:
org.apache.activemq.artemis.core.persistence.Persister<org.apache.activemq.artemis.api.core.Message>
public class MessagePersister extends Object implements org.apache.activemq.artemis.core.persistence.Persister<org.apache.activemq.artemis.api.core.Message>

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    MessagePersister()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static void
    clearPersisters()
     
    org.apache.activemq.artemis.api.core.Message
    decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, org.apache.activemq.artemis.api.core.Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)
     
    org.apache.activemq.artemis.api.core.Message
    decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, org.apache.activemq.artemis.api.core.Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools, org.apache.activemq.artemis.core.persistence.StorageManager storageManager)
     
    void
    encode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, org.apache.activemq.artemis.api.core.Message record)
    Sub classes must add the first short as the protocol-id
    int
    getEncodeSize(org.apache.activemq.artemis.api.core.Message record)
     
    byte
    getID()
     
    static MessagePersister
    getInstance()
     
    static org.apache.activemq.artemis.core.persistence.Persister
    getPersister(byte id)
     
    static void
    registerPersister(org.apache.activemq.artemis.core.persistence.Persister<org.apache.activemq.artemis.api.core.Message> persister)
     
    static void
    registerProtocol(ProtocolManagerFactory manager)
     

    Methods inherited from class Object

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

  • Constructor Details

    • MessagePersister

      protected MessagePersister()

  • Method Details

    • getID

      public byte getID()
      Specified by:
      getID in interface org.apache.activemq.artemis.core.persistence.Persister<org.apache.activemq.artemis.api.core.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<org.apache.activemq.artemis.api.core.Message> persister)

    • getInstance

      public static MessagePersister getInstance()

    • getEncodeSize

      public int getEncodeSize(org.apache.activemq.artemis.api.core.Message record)
      Specified by:
      getEncodeSize in interface org.apache.activemq.artemis.core.persistence.Persister<org.apache.activemq.artemis.api.core.Message>

    • encode

      public void encode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, org.apache.activemq.artemis.api.core.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<org.apache.activemq.artemis.api.core.Message>

    • decode

      public org.apache.activemq.artemis.api.core.Message decode(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, org.apache.activemq.artemis.api.core.Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)
      Specified by:
      decode in interface org.apache.activemq.artemis.core.persistence.Persister<org.apache.activemq.artemis.api.core.Message>

    • decode

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