Package org.apache.commons.jcs3.engine
Class CacheEventQueue<K,V>
java.lang.Object
org.apache.commons.jcs3.engine.AbstractCacheEventQueue<K,V>
org.apache.commons.jcs3.engine.PooledCacheEventQueue<K,V>
org.apache.commons.jcs3.engine.CacheEventQueue<K,V>
- All Implemented Interfaces:
ICacheEventQueue<K,V>
An event queue is used to propagate ordered cache events to one and only one target listener.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.commons.jcs3.engine.AbstractCacheEventQueue
AbstractCacheEventQueue.AbstractCacheEvent, AbstractCacheEventQueue.DisposeEvent, AbstractCacheEventQueue.PutEvent, AbstractCacheEventQueue.RemoveAllEvent, AbstractCacheEventQueue.RemoveEventNested classes/interfaces inherited from interface org.apache.commons.jcs3.engine.behavior.ICacheEventQueue
ICacheEventQueue.QueueType -
Field Summary
Fields inherited from class org.apache.commons.jcs3.engine.PooledCacheEventQueue
pool, queueFields inherited from class org.apache.commons.jcs3.engine.AbstractCacheEventQueue
DEFAULT_WAIT_TO_DIE_MILLIS -
Constructor Summary
ConstructorsConstructorDescriptionCacheEventQueue(ICacheListener<K, V> listener, long listenerId, String cacheName) Constructs with the specified listener and the cache name.CacheEventQueue(ICacheListener<K, V> listener, long listenerId, String cacheName, int maxFailure, int waitBeforeRetry) Constructor for the CacheEventQueue object -
Method Summary
Modifier and TypeMethodDescriptionprotected ExecutorServicecreatePool(String threadPoolName) Create the thread pool.What type of queue is this.Methods inherited from class org.apache.commons.jcs3.engine.PooledCacheEventQueue
destroy, getStatistics, initialize, isEmpty, put, sizeMethods inherited from class org.apache.commons.jcs3.engine.AbstractCacheEventQueue
addDisposeEvent, addPutEvent, addRemoveAllEvent, addRemoveEvent, getCacheName, getListenerId, getWaitToDieMillis, initialize, isWorking, setWaitToDieMillis, setWorking, toString
-
Constructor Details
-
CacheEventQueue
Constructs with the specified listener and the cache name.- Parameters:
listener-listenerId-cacheName-
-
CacheEventQueue
public CacheEventQueue(ICacheListener<K, V> listener, long listenerId, String cacheName, int maxFailure, int waitBeforeRetry) Constructor for the CacheEventQueue object- Parameters:
listener-listenerId-cacheName-maxFailure-waitBeforeRetry-
-
-
Method Details
-
createPool
Create the thread pool.- Overrides:
createPoolin classPooledCacheEventQueue<K,V> - Parameters:
threadPoolName-- Since:
- 3.1
-
getQueueType
What type of queue is this.- Specified by:
getQueueTypein interfaceICacheEventQueue<K,V> - Overrides:
getQueueTypein classPooledCacheEventQueue<K,V> - Returns:
- queueType
-