Package org.apache.activemq.store.kahadb

Class TempKahaDBStore.KahaDBMessageStore

java.lang.Object
org.apache.activemq.store.AbstractMessageStore
org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
All Implemented Interfaces:
org.apache.activemq.Service, org.apache.activemq.store.MessageStore
Enclosing class:
TempKahaDBStore
public class TempKahaDBStore.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 KahaDestination
    dest
     

    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
    void
    addMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.Message message)
     
    org.apache.activemq.command.ActiveMQDestination
    getDestination()
     
    org.apache.activemq.command.Message
    getMessage(org.apache.activemq.command.MessageId identity)
     
    org.apache.activemq.store.MessageStore.StoreType
    getType()
     
    void
    recover(org.apache.activemq.store.MessageRecoveryListener listener)
     
    void
    recoverMessageStoreStatistics()
     
    void
    recoverNextMessages(int maxReturned, org.apache.activemq.store.MessageRecoveryListener listener)
     
    void
    removeAllMessages(org.apache.activemq.broker.ConnectionContext context)
     
    void
    removeMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.MessageAck ack)
     
    void
    resetBatching()
     
    void
    setBatch(org.apache.activemq.command.MessageId identity)
     
    void
    setMemoryUsage(org.apache.activemq.usage.MemoryUsage memoryUsage)
     
    void
    start()
     
    void
    stop()
     

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

    addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getIndexListener, getMessageCount, getMessageSize, getMessageStoreStatistics, isEmpty, isPrioritizedMessages, registerIndexListener, removeAsyncMessage, setPrioritizedMessages, updateMessage

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.activemq.store.MessageStore

    recoverMessages

  • Field Details

  • Constructor Details

    • KahaDBMessageStore

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

  • Method Details

    • getDestination

      public org.apache.activemq.command.ActiveMQDestination getDestination()
      Specified by:
      getDestination in interface org.apache.activemq.store.MessageStore
      Overrides:
      getDestination in class org.apache.activemq.store.AbstractMessageStore

    • addMessage

      public void addMessage(org.apache.activemq.broker.ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
      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

    • 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

    • 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

    • setMemoryUsage

      public void setMemoryUsage(org.apache.activemq.usage.MemoryUsage memoryUsage)
      Specified by:
      setMemoryUsage in interface org.apache.activemq.store.MessageStore
      Overrides:
      setMemoryUsage in class org.apache.activemq.store.AbstractMessageStore

    • start

      public void start() throws Exception
      Specified by:
      start in interface org.apache.activemq.Service
      Overrides:
      start in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      Exception

    • stop

      public void stop() throws Exception
      Specified by:
      stop in interface org.apache.activemq.Service
      Overrides:
      stop in class org.apache.activemq.store.AbstractMessageStore
      Throws:
      Exception

    • recoverMessageStoreStatistics

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

    • getType

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