Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep
A B C D G I L M O P R S

A

addMessage(ActiveMQMessage) - Method in class org.activemq.store.cache.CacheMessageStore
Add the meessage to the long term store and cache it.

B

beginTransaction() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
beginTransaction() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 

C

CacheMessageStore - class org.activemq.store.cache.CacheMessageStore.
A MessageStore that uses an in memory cache to speed up getMessage() method calls.
CacheMessageStore(CachePersistenceAdapter, MessageStore, MessageCache) - Constructor for class org.activemq.store.cache.CacheMessageStore
 
CacheMessageStoreAware - interface org.activemq.store.cache.CacheMessageStoreAware.
Other MessageStores that whish to be notified when they are being cached by a CacheMessageStore should implement the CacheMessageStoreAware interface.
CachePersistenceAdapter - class org.activemq.store.cache.CachePersistenceAdapter.
Implements a org.activemq.store.PersistenceAdapter designed to to speed up access to recently added messages by using a MessageCache .
CachePersistenceAdapter() - Constructor for class org.activemq.store.cache.CachePersistenceAdapter
 
CachePersistenceAdapter(PersistenceAdapter) - Constructor for class org.activemq.store.cache.CachePersistenceAdapter
 
CacheTopicMessageStore - class org.activemq.store.cache.CacheTopicMessageStore.
A MessageStore that uses an in memory cache to speed up getMessage() method calls.
CacheTopicMessageStore(CachePersistenceAdapter, TopicMessageStore, MessageCache) - Constructor for class org.activemq.store.cache.CacheTopicMessageStore
 
cache - Variable in class org.activemq.store.cache.CacheMessageStore
 
cacheSize - Variable in class org.activemq.store.cache.SimpleCachePersistenceAdapter
 
cacheSize - Variable in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
close() - Method in interface org.activemq.store.cache.MessageCache
Lets a cache know it will not be used any further and that it can release aquired resources
close() - Method in class org.activemq.store.cache.SimpleMessageCache
 
commitTransaction() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
commitTransaction() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
createMessageCache(String) - Method in class org.activemq.store.cache.CachePersistenceAdapter
Subclasses should override this method to change the type of MessageCache that is used to cache messages.
createMessageCache(String) - Method in class org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter
 
createMessageCache(String) - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapter
 
createQueueMessageStore(String) - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
createQueueMessageStore(String) - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
createTopicMessageStore(String) - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
createTopicMessageStore(String) - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
createTransactionStore() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
createTransactionStore() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 

D

deadLetterAlreadySent(long, boolean) - Method in class org.activemq.store.cache.CachePersistenceAdapter
Verifies if a dead letter has already been sent for a message
deadLetterAlreadySent(long, boolean) - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
decrementMessageCountAndMaybeDelete(MessageIdentity) - Method in class org.activemq.store.cache.CacheTopicMessageStore
 
deleteSubscription(String) - Method in class org.activemq.store.cache.CacheTopicMessageStore
 
doFail() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
doStart() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
doStop() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 

G

GBEAN_INFO - Static variable in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
get(String) - Method in interface org.activemq.store.cache.MessageCache
Gets a message that was previously put into this object.
get(String) - Method in class org.activemq.store.cache.SimpleMessageCache
Gets a message that was previously put into this object.
getCacheSize() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapter
 
getGBeanInfo() - Static method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
getInitialDestinations() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
getInitialDestinations() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
getLastestMessageIdentity() - Method in class org.activemq.store.cache.CacheTopicMessageStore
 
getLongTermPersistence() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
getLongTermStore() - Method in class org.activemq.store.cache.CacheMessageStore
 
getMemoryManager() - Method in class org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter
 
getMessage(MessageIdentity) - Method in class org.activemq.store.cache.CacheMessageStore
Return the message from the cache or go to the longTermStore if it is not in there.
getSubscriberEntry(ConsumerInfo) - Method in class org.activemq.store.cache.CacheTopicMessageStore
 

I

incrementMessageCount(MessageIdentity) - Method in class org.activemq.store.cache.CacheTopicMessageStore
 

L

longTermPersistence - Variable in class org.activemq.store.cache.CachePersistenceAdapter
 
longTermPersistence - Variable in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
longTermStore - Variable in class org.activemq.store.cache.CacheMessageStore
 
longTermStore - Variable in class org.activemq.store.cache.CacheTopicMessageStore
 

M

MemoryBoundedCachePersistenceAdapter - class org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter.
Provides a CachePersistenceAdapter that uses a MemoryBoundedLRUCache for each destination.
MemoryBoundedCachePersistenceAdapter() - Constructor for class org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter
 
MemoryBoundedCachePersistenceAdapter(PersistenceAdapter) - Constructor for class org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter
 
MessageCache - interface org.activemq.store.cache.MessageCache.
Defines the interface used to cache messages.
memoryManager - Variable in class org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter
 
messages - Variable in class org.activemq.store.cache.SimpleMessageCache
 

O

org.activemq.store.cache - package org.activemq.store.cache
 

P

persistenceAdapter - Variable in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
put(String, ActiveMQMessage) - Method in interface org.activemq.store.cache.MessageCache
Puts a message into the cache.
put(String, ActiveMQMessage) - Method in class org.activemq.store.cache.SimpleMessageCache
Puts a message into the cache.

R

recover(RecoveryListener) - Method in class org.activemq.store.cache.CacheMessageStore
Replays the checkpointStore first as those messages are the oldest ones, then messages are replayed from the transaction log and then the cache is updated.
recoverSubscription(String, MessageIdentity, RecoveryListener) - Method in class org.activemq.store.cache.CacheTopicMessageStore
 
remove(String) - Method in interface org.activemq.store.cache.MessageCache
Remvoes a message from the cache.
remove(String) - Method in class org.activemq.store.cache.SimpleMessageCache
Remvoes a message from the cache.
removeAllMessages() - Method in class org.activemq.store.cache.CacheMessageStore
 
removeMessage(MessageAck) - Method in class org.activemq.store.cache.CacheMessageStore
Remove the meessage to the long term store and remove it from the cache.
rollbackTransaction() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
rollbackTransaction() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 

S

SimpleCachePersistenceAdapter - class org.activemq.store.cache.SimpleCachePersistenceAdapter.
Provides a CachePersistenceAdapter that uses a seperate LRU cache for each destination.
SimpleCachePersistenceAdapter() - Constructor for class org.activemq.store.cache.SimpleCachePersistenceAdapter
 
SimpleCachePersistenceAdapter(PersistenceAdapter) - Constructor for class org.activemq.store.cache.SimpleCachePersistenceAdapter
 
SimpleCachePersistenceAdapterGBean - class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean.
 
SimpleCachePersistenceAdapterGBean() - Constructor for class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
SimpleCachePersistenceAdapterGBean(PersistenceAdapter, int) - Constructor for class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
SimpleMessageCache - class org.activemq.store.cache.SimpleMessageCache.
A simple cache that stores messages in memory.
SimpleMessageCache() - Constructor for class org.activemq.store.cache.SimpleMessageCache
 
SimpleMessageCache(int) - Constructor for class org.activemq.store.cache.SimpleMessageCache
 
setCacheMessageStore(CacheMessageStore) - Method in class org.activemq.store.cache.CacheMessageStore
 
setCacheMessageStore(CacheMessageStore) - Method in interface org.activemq.store.cache.CacheMessageStoreAware
 
setCacheSize(int) - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapter
 
setLastAcknowledgedMessageIdentity(String, MessageIdentity) - Method in class org.activemq.store.cache.CacheTopicMessageStore
 
setLongTermPersistence(PersistenceAdapter) - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
setMemoryManager(MemoryBoundedObjectManager) - Method in class org.activemq.store.cache.MemoryBoundedCachePersistenceAdapter
 
setSubscriberEntry(ConsumerInfo, SubscriberEntry) - Method in class org.activemq.store.cache.CacheTopicMessageStore
 
start() - Method in class org.activemq.store.cache.CacheMessageStore
 
start() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
start() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 
stop() - Method in class org.activemq.store.cache.CacheMessageStore
 
stop() - Method in class org.activemq.store.cache.CachePersistenceAdapter
 
stop() - Method in class org.activemq.store.cache.SimpleCachePersistenceAdapterGBean
 

A B C D G I L M O P R S