Package org.apache.activemq.store.kahadb

Class TempKahaDBStore

java.lang.Object
org.apache.activemq.store.kahadb.TempMessageDatabase
org.apache.activemq.store.kahadb.TempKahaDBStore
All Implemented Interfaces:
org.apache.activemq.broker.BrokerServiceAware, org.apache.activemq.Service, org.apache.activemq.store.PersistenceAdapter
public class TempKahaDBStore extends TempMessageDatabase implements org.apache.activemq.store.PersistenceAdapter, org.apache.activemq.broker.BrokerServiceAware

  • Constructor Details

    • TempKahaDBStore

      public TempKahaDBStore()

  • Method Details

    • setBrokerName

      public void setBrokerName(String brokerName)
      Specified by:
      setBrokerName in interface org.apache.activemq.store.PersistenceAdapter

    • setUsageManager

      public void setUsageManager(org.apache.activemq.usage.SystemUsage usageManager)
      Specified by:
      setUsageManager in interface org.apache.activemq.store.PersistenceAdapter

    • createTransactionStore

      public org.apache.activemq.store.TransactionStore createTransactionStore() throws IOException
      Specified by:
      createTransactionStore in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • createQueueMessageStore

      public org.apache.activemq.store.MessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue destination) throws IOException
      Specified by:
      createQueueMessageStore in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • createTopicMessageStore

      public org.apache.activemq.store.TopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic destination) throws IOException
      Specified by:
      createTopicMessageStore in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • removeQueueMessageStore

      public void removeQueueMessageStore(org.apache.activemq.command.ActiveMQQueue destination)
      Cleanup method to remove any state associated with the given destination. This method does not stop the message store (it might not be cached).
      Specified by:
      removeQueueMessageStore in interface org.apache.activemq.store.PersistenceAdapter
      Parameters:
      destination - Destination to forget

    • removeTopicMessageStore

      public void removeTopicMessageStore(org.apache.activemq.command.ActiveMQTopic destination)
      Cleanup method to remove any state associated with the given destination This method does not stop the message store (it might not be cached).
      Specified by:
      removeTopicMessageStore in interface org.apache.activemq.store.PersistenceAdapter
      Parameters:
      destination - Destination to forget

    • deleteAllMessages

      public void deleteAllMessages() throws IOException
      Specified by:
      deleteAllMessages in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • getDestinations

      public Set<org.apache.activemq.command.ActiveMQDestination> getDestinations()
      Specified by:
      getDestinations in interface org.apache.activemq.store.PersistenceAdapter

    • getLastMessageBrokerSequenceId

      public long getLastMessageBrokerSequenceId() throws IOException
      Specified by:
      getLastMessageBrokerSequenceId in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • size

      public long size()
      Specified by:
      size in interface org.apache.activemq.store.PersistenceAdapter

    • beginTransaction

      public void beginTransaction(org.apache.activemq.broker.ConnectionContext context) throws IOException
      Specified by:
      beginTransaction in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • commitTransaction

      public void commitTransaction(org.apache.activemq.broker.ConnectionContext context) throws IOException
      Specified by:
      commitTransaction in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • rollbackTransaction

      public void rollbackTransaction(org.apache.activemq.broker.ConnectionContext context) throws IOException
      Specified by:
      rollbackTransaction in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • checkpoint

      public void checkpoint(boolean sync) throws IOException
      Specified by:
      checkpoint in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException

    • getLastProducerSequenceId

      public long getLastProducerSequenceId(org.apache.activemq.command.ProducerId id)
      Specified by:
      getLastProducerSequenceId in interface org.apache.activemq.store.PersistenceAdapter

    • allowIOResumption

      public void allowIOResumption()
      Specified by:
      allowIOResumption in interface org.apache.activemq.store.PersistenceAdapter

    • setBrokerService

      public void setBrokerService(org.apache.activemq.broker.BrokerService brokerService)
      Specified by:
      setBrokerService in interface org.apache.activemq.broker.BrokerServiceAware

    • load

      public void load() throws IOException
      Overrides:
      load in class TempMessageDatabase
      Throws:
      IOException

    • createJobSchedulerStore

      public org.apache.activemq.broker.scheduler.JobSchedulerStore createJobSchedulerStore() throws IOException, UnsupportedOperationException
      Specified by:
      createJobSchedulerStore in interface org.apache.activemq.store.PersistenceAdapter
      Throws:
      IOException
      UnsupportedOperationException