Package org.apache.activemq.store.kahadb

Class KahaDBStore.KahaDBMessageStore

java.lang.Object
org.apache.activemq.store.AbstractMessageStore
org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
All Implemented Interfaces:
org.apache.activemq.Service, org.apache.activemq.store.MessageStore
Enclosing class:
KahaDBStore
public class KahaDBStore.KahaDBMessageStore extends org.apache.activemq.store.AbstractMessageStore

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.activemq.store.MessageStore

    org.apache.activemq.store.MessageStore.StoreType

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final HashMap<String,Set<String>>
    ackedAndPreparedMap
     
    protected KahaDestination
    dest
     
    protected final HashMap<String,Set<String>>
    rolledBackAcksMap
     

    Fields inherited from class org.apache.activemq.store.AbstractMessageStore

    destination, FUTURE, indexListener, messageStoreStatistics, prioritizedMessages

  • Constructor Summary

    Constructors
    Constructor
    Description
    KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    acquireLocalAsyncLock()
     
    void
    addMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.Message message)
     
    org.apache.activemq.store.ListenableFuture<Object>
    asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.Message message)
     
    void
    forgetRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks, boolean rollback)
     
    org.apache.activemq.command.Message
    getMessage(org.apache.activemq.command.MessageId identity)
     
    org.apache.activemq.store.MessageStore.StoreType
    getType()
     
    boolean
    isEmpty()
     
    protected void
    lockAsyncJobQueue()
     
    void
    recover(org.apache.activemq.store.MessageRecoveryListener listener)
     
    void
    recoverMessages(org.apache.activemq.store.MessageRecoveryContext messageRecoveryContext)
     
    protected void
    recoverMessageStoreStatistics()
     
    void
    recoverNextMessages(int maxReturned, org.apache.activemq.store.MessageRecoveryListener listener)
     
    protected void
    releaseLocalAsyncLock()
     
    void
    removeAllMessages(org.apache.activemq.broker.ConnectionContext context)
     
    void
    removeAsyncMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.MessageAck ack)
     
    void
    removeMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.MessageAck ack)
     
    void
    resetBatching()
     
    void
    setBatch(org.apache.activemq.command.MessageId identity)
     
    String
    toString()
     
    void
    trackRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks)
     
    protected void
    unlockAsyncJobQueue()
     
    void
    updateMessage(org.apache.activemq.command.Message message)
     

    Methods inherited from class org.apache.activemq.store.AbstractMessageStore

    addMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getIndexListener, getMessageCount, getMessageSize, getMessageStoreStatistics, isPrioritizedMessages, registerIndexListener, setMemoryUsage, setPrioritizedMessages, start, stop

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • KahaDBMessageStore

      public KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination)

  • Method Details

    • trackRecoveredAcks

      public void trackRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks)

    • forgetRecoveredAcks

      public void forgetRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks, boolean rollback) throws IOException
      Throws:
      IOException

    • asyncAddQueueMessage

      public org.apache.activemq.store.ListenableFuture<Object> asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
      Specified by:
      asyncAddQueueMessage in interface org.apache.activemq.store.MessageStore
      Overrides:
      asyncAddQueueMessage in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      IOException

    • removeAsyncMessage

      public void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.MessageAck ack) throws IOException
      Specified by:
      removeAsyncMessage in interface org.apache.activemq.store.MessageStore
      Overrides:
      removeAsyncMessage in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      IOException

    • addMessage

      public void addMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
      Throws:
      IOException

    • updateMessage

      public void updateMessage(org.apache.activemq.command.Message message) throws IOException
      Specified by:
      updateMessage in interface org.apache.activemq.store.MessageStore
      Overrides:
      updateMessage in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      IOException

    • removeMessage

      public void removeMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.MessageAck ack) throws IOException
      Throws:
      IOException

    • removeAllMessages

      public void removeAllMessages(org.apache.activemq.broker.ConnectionContext context) throws IOException
      Throws:
      IOException

    • getMessage

      public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId identity) throws IOException
      Throws:
      IOException

    • isEmpty

      public boolean isEmpty() throws IOException
      Specified by:
      isEmpty in interface org.apache.activemq.store.MessageStore
      Overrides:
      isEmpty in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      IOException

    • recover

      public void recover(org.apache.activemq.store.MessageRecoveryListener listener) throws Exception
      Throws:
      Exception

    • recoverNextMessages

      public void recoverNextMessages(int maxReturned, org.apache.activemq.store.MessageRecoveryListener listener) throws Exception
      Throws:
      Exception

    • recoverMessages

      public void recoverMessages(org.apache.activemq.store.MessageRecoveryContext messageRecoveryContext) throws Exception
      Throws:
      Exception

    • resetBatching

      public void resetBatching()

    • setBatch

      public void setBatch(org.apache.activemq.command.MessageId identity) throws IOException
      Specified by:
      setBatch in interface org.apache.activemq.store.MessageStore
      Overrides:
      setBatch in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      IOException

    • lockAsyncJobQueue

      protected void lockAsyncJobQueue()

    • unlockAsyncJobQueue

      protected void unlockAsyncJobQueue()

    • acquireLocalAsyncLock

      protected void acquireLocalAsyncLock()

    • releaseLocalAsyncLock

      protected void releaseLocalAsyncLock()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • recoverMessageStoreStatistics

      protected void recoverMessageStoreStatistics() throws IOException
      Overrides:
      recoverMessageStoreStatistics in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      IOException

    • getType

      public org.apache.activemq.store.MessageStore.StoreType getType()