Home » activemq-parent-5.3.1-source-release » org.apache » activemq » store » journal » [javadoc | source]
org.apache.activemq.store.journal
public class: JournalTopicMessageStore [javadoc | source]
java.lang.Object
   org.apache.activemq.store.AbstractMessageStore
      org.apache.activemq.store.journal.JournalMessageStore
         org.apache.activemq.store.journal.JournalTopicMessageStore

All Implemented Interfaces:
    TopicMessageStore, MessageStore

A MessageStore that uses a Journal to store it's messages.
Fields inherited from org.apache.activemq.store.journal.JournalMessageStore:
peristenceAdapter,  transactionStore,  longTermStore,  transactionTemplate,  lastLocation,  inFlightTxLocations
Fields inherited from org.apache.activemq.store.AbstractMessageStore:
destination
Constructor:
 public JournalTopicMessageStore(JournalPersistenceAdapter adapter,
    TopicMessageStore checkpointStore,
    ActiveMQTopic destinationName) 
Method from org.apache.activemq.store.journal.JournalTopicMessageStore Summary:
acknowledge,   acknowledge,   addMessage,   addSubsciption,   checkpoint,   deleteSubscription,   getAllSubscriptions,   getLongTermTopicMessageStore,   getMessageCount,   lookupSubscription,   recoverNextMessages,   recoverSubscription,   replayAcknowledge,   resetBatching
Methods from org.apache.activemq.store.journal.JournalMessageStore:
addMessage,   addMessage,   addMessageReference,   checkpoint,   checkpoint,   getLongTermMessageStore,   getMessage,   getMessageCount,   getMessageReference,   recover,   recoverNextMessages,   removeAllMessages,   removeMessage,   removeMessage,   replayAddMessage,   replayRemoveMessage,   resetBatching,   setBatch,   setMemoryUsage,   start,   stop
Methods from org.apache.activemq.store.AbstractMessageStore:
dispose,   getDestination,   isEmpty,   setBatch,   setMemoryUsage,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.journal.JournalTopicMessageStore Detail:
 protected  void acknowledge(MessageId messageId,
    RecordLocation location,
    SubscriptionKey key) 
 public  void acknowledge(ConnectionContext context,
    String clientId,
    String subscriptionName,
    MessageId messageId) throws IOException 
 public  void addMessage(ConnectionContext context,
    Message message) throws IOException 
 public  void addSubsciption(SubscriptionInfo subscriptionInfo,
    boolean retroactive) throws IOException 
 public RecordLocation checkpoint() throws IOException 
 public  void deleteSubscription(String clientId,
    String subscriptionName) throws IOException 
 public SubscriptionInfo[] getAllSubscriptions() throws IOException 
 public TopicMessageStore getLongTermTopicMessageStore() 
 public int getMessageCount(String clientId,
    String subscriberName) throws IOException 
 public SubscriptionInfo lookupSubscription(String clientId,
    String subscriptionName) throws IOException 
 public  void recoverNextMessages(String clientId,
    String subscriptionName,
    int maxReturned,
    MessageRecoveryListener listener) throws Exception 
 public  void recoverSubscription(String clientId,
    String subscriptionName,
    MessageRecoveryListener listener) throws Exception 
 public  void replayAcknowledge(ConnectionContext context,
    String clientId,
    String subscritionName,
    MessageId messageId) 
 public  void resetBatching(String clientId,
    String subscriptionName)