org.activemq.store.cache
Class MemoryBoundedCachePersistenceAdapter
java.lang.Object
org.activemq.store.cache.CachePersistenceAdapter
org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter
- All Implemented Interfaces:
- Service, PersistenceAdapter
public class MemoryBoundedCachePersistenceAdapter
- extends CachePersistenceAdapter
Provides a CachePersistenceAdapter that uses a MemoryBoundedLRUCache
for each destination.
- Version:
- $Revision: 1.1.1.1 $
Methods inherited from class org.activemq.store.cache.CachePersistenceAdapter |
beginTransaction, commitTransaction, createQueueMessageStore, createTopicMessageStore, createTransactionStore, deadLetterAlreadySent, getInitialDestinations, getLongTermPersistence, rollbackTransaction, setLongTermPersistence, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MemoryBoundedCachePersistenceAdapter
public MemoryBoundedCachePersistenceAdapter()
MemoryBoundedCachePersistenceAdapter
public MemoryBoundedCachePersistenceAdapter(PersistenceAdapter longTermPersistence)
throws IOException
- Throws:
IOException
createMessageCache
protected MessageCache createMessageCache(String destinationName)
- Description copied from class:
CachePersistenceAdapter
- Subclasses should override this method to change the type
of MessageCache that is used to cache messages.
- Specified by:
createMessageCache
in class CachePersistenceAdapter
- Returns:
- See Also:
CachePersistenceAdapter.createMessageCache(java.lang.String)
getMemoryManager
public MemoryBoundedObjectManager getMemoryManager()
- Returns:
- Returns the memoryManager.
setMemoryManager
public void setMemoryManager(MemoryBoundedObjectManager memoryManager)
- Parameters:
memoryManager
- The memoryManager to set.
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.