public class CacheEventQueue<K,V> extends PooledCacheEventQueue<K,V>
AbstractCacheEventQueue.AbstractCacheEvent, AbstractCacheEventQueue.DisposeEvent, AbstractCacheEventQueue.PutEvent, AbstractCacheEventQueue.RemoveAllEvent, AbstractCacheEventQueue.RemoveEventICacheEventQueue.QueueTypepool, queueDEFAULT_WAIT_TO_DIE_MILLIS| Constructor and Description |
|---|
CacheEventQueue(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
|
| Modifier and Type | Method and Description |
|---|---|
protected ExecutorService |
createPool(String threadPoolName)
Create the thread pool.
|
ICacheEventQueue.QueueType |
getQueueType()
What type of queue is this.
|
destroy, getStatistics, initialize, isEmpty, put, sizeaddDisposeEvent, addPutEvent, addRemoveAllEvent, addRemoveEvent, getCacheName, getListenerId, getWaitToDieMillis, initialize, isWorking, setWaitToDieMillis, setWorking, toStringpublic CacheEventQueue(ICacheListener<K,V> listener, long listenerId, String cacheName)
listener - listenerId - cacheName - public CacheEventQueue(ICacheListener<K,V> listener, long listenerId, String cacheName, int maxFailure, int waitBeforeRetry)
listener - listenerId - cacheName - maxFailure - waitBeforeRetry - protected ExecutorService createPool(String threadPoolName)
createPool in class PooledCacheEventQueue<K,V>threadPoolName - public ICacheEventQueue.QueueType getQueueType()
getQueueType in interface ICacheEventQueue<K,V>getQueueType in class PooledCacheEventQueue<K,V>Copyright © 2002–2022 The Apache Software Foundation. All rights reserved.