public interface ICacheEventQueue
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
POOLED_QUEUE_TYPE
Uses a thread pool
|
static java.lang.String |
SINGLE_QUEUE_TYPE
Does not use a thread pool.
|
Modifier and Type | Method and Description |
---|---|
void |
addDisposeEvent()
Adds a feature to the DisposeEvent attribute of the ICacheEventQueue
object
|
void |
addPutEvent(ICacheElement ce)
Adds a feature to the PutEvent attribute of the ICacheEventQueue object
|
void |
addRemoveAllEvent()
Adds a feature to the RemoveAllEvent attribute of the ICacheEventQueue
object
|
void |
addRemoveEvent(java.io.Serializable key)
Adds a feature to the RemoveEvent attribute of the ICacheEventQueue
object
|
void |
destroy()
Description of the Method
|
long |
getListenerId()
Gets the listenerId attribute of the ICacheEventQueue object
|
java.lang.String |
getQueueType()
Return the type of event queue we are using, either single or pooled.
|
IStats |
getStatistics()
Returns the historical and statistical data for an event queue cache.
|
void |
initialize(ICacheListener listener,
long listenerId,
java.lang.String cacheName,
int maxFailure,
int waitBeforeRetry,
java.lang.String threadPoolName)
Initializes the queue.
|
boolean |
isAlive()
Gets the alive attribute of the ICacheEventQueue object.
|
boolean |
isEmpty()
Are there elements in the queue.
|
boolean |
isWorking()
A Queue is working unless it has reached its max failure count.
|
int |
size()
Returns the number of elements in the queue.
|
static final java.lang.String SINGLE_QUEUE_TYPE
static final java.lang.String POOLED_QUEUE_TYPE
void initialize(ICacheListener listener, long listenerId, java.lang.String cacheName, int maxFailure, int waitBeforeRetry, java.lang.String threadPoolName)
listener
- listenerId
- cacheName
- maxFailure
- waitBeforeRetry
- threadPoolName
- java.lang.String getQueueType()
void addPutEvent(ICacheElement ce) throws java.io.IOException
ce
- The feature to be added to the PutEvent attributejava.io.IOException
void addRemoveEvent(java.io.Serializable key) throws java.io.IOException
key
- The feature to be added to the RemoveEvent attributejava.io.IOException
void addRemoveAllEvent() throws java.io.IOException
java.io.IOException
void addDisposeEvent() throws java.io.IOException
java.io.IOException
long getListenerId()
void destroy()
boolean isAlive()
boolean isWorking()
int size()
boolean isEmpty()
IStats getStatistics()
Copyright © 2002-2013 Apache Software Foundation. All Rights Reserved.