org.apache.activemq.store
Class AbstractMessageStore

java.lang.Object
  extended by org.apache.activemq.store.AbstractMessageStore
All Implemented Interfaces:
Service, MessageStore
Direct Known Subclasses:
AMQMessageStore, JDBCMessageStore, JournalMessageStore, KahaDBStore.KahaDBMessageStore, KahaMessageStore, KahaReferenceStore, MemoryMessageStore, TempKahaDBStore.KahaDBMessageStore

public abstract class AbstractMessageStore
extends Object
implements MessageStore


Field Summary
protected  ActiveMQDestination destination
           
 
Constructor Summary
AbstractMessageStore(ActiveMQDestination destination)
           
 
Method Summary
 void dispose(ConnectionContext context)
           
 ActiveMQDestination getDestination()
          The destination that the message store is holding messages for.
 boolean isEmpty()
          flag to indicate if the store is empty
 void setBatch(MessageId messageId)
          allow caching cursors to set the current batch offset when cache is exhausted
 void setMemoryUsage(MemoryUsage memoryUsage)
           
 void start()
           
 void stop()
           
 
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
addMessage, getMessage, getMessageCount, recover, recoverNextMessages, removeAllMessages, removeMessage, resetBatching
 

Field Detail

destination

protected final ActiveMQDestination destination
Constructor Detail

AbstractMessageStore

public AbstractMessageStore(ActiveMQDestination destination)
Method Detail

dispose

public void dispose(ConnectionContext context)
Specified by:
dispose in interface MessageStore

start

public void start()
           throws Exception
Specified by:
start in interface Service
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Throws:
Exception

getDestination

public ActiveMQDestination getDestination()
Description copied from interface: MessageStore
The destination that the message store is holding messages for.

Specified by:
getDestination in interface MessageStore
Returns:
the destination

setMemoryUsage

public void setMemoryUsage(MemoryUsage memoryUsage)
Specified by:
setMemoryUsage in interface MessageStore
Parameters:
memoryUsage - The SystemUsage that is controlling the destination's memory usage.

setBatch

public void setBatch(MessageId messageId)
              throws IOException,
                     Exception
Description copied from interface: MessageStore
allow caching cursors to set the current batch offset when cache is exhausted

Specified by:
setBatch in interface MessageStore
Throws:
Exception
IOException

isEmpty

public boolean isEmpty()
                throws Exception
flag to indicate if the store is empty

Specified by:
isEmpty in interface MessageStore
Returns:
true if the message count is 0
Throws:
Exception


Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.