public interface  org.apache.activemq.store.MessageStore extends java.lang.Object implements org.apache.activemq.Service
{
public abstract void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException;
public abstract void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException;
public abstract org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException;
public abstract org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException;
public abstract org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException;
public abstract org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException;
public abstract org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId) throws java.io.IOException;
public abstract void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.io.IOException;
public abstract void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.io.IOException;
public abstract void removeAllMessages(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException;
public abstract void recover(org.apache.activemq.store.MessageRecoveryListener) throws java.lang.Exception;
public abstract org.apache.activemq.command.ActiveMQDestination getDestination();
public abstract void setMemoryUsage(org.apache.activemq.usage.MemoryUsage);
public abstract int getMessageCount() throws java.io.IOException;
public abstract long getMessageSize() throws java.io.IOException;
public abstract org.apache.activemq.store.MessageStoreStatistics getMessageStoreStatistics();
public abstract void resetBatching();
public abstract void recoverNextMessages(int, org.apache.activemq.store.MessageRecoveryListener) throws java.lang.Exception;
public abstract void dispose(org.apache.activemq.broker.ConnectionContext);
public abstract void setBatch(org.apache.activemq.command.MessageId) throws java.lang.Exception;
public abstract boolean isEmpty() throws java.lang.Exception;
public abstract void setPrioritizedMessages(boolean);
public abstract boolean isPrioritizedMessages();
public abstract void updateMessage(org.apache.activemq.command.Message) throws java.io.IOException;
public abstract void registerIndexListener(org.apache.activemq.store.IndexListener);
}