public class CacheEventQueue<K,V> extends PooledCacheEventQueue<K,V>
AbstractCacheEventQueue.AbstractCacheEvent, AbstractCacheEventQueue.DisposeEvent, AbstractCacheEventQueue.PutEvent, AbstractCacheEventQueue.RemoveAllEvent, AbstractCacheEventQueue.RemoveEvent
ICacheEventQueue.QueueType
pool, queue
DEFAULT_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, size
addDisposeEvent, addPutEvent, addRemoveAllEvent, addRemoveEvent, getCacheName, getListenerId, getWaitToDieMillis, initialize, isWorking, setWaitToDieMillis, setWorking, toString
public 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.