org.apache.activemq.store
Class AbstractMessageStore
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
destination
protected final ActiveMQDestination destination
AbstractMessageStore
public AbstractMessageStore(ActiveMQDestination destination)
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.