public class AsyncEventQueueFactoryBean extends AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
AsyncEventQueue
s.cache, factory, log, VALID_ORDER_POLICIES
Constructor and Description |
---|
AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache)
Constructs an instance of the AsyncEventQueueFactoryBean for creating an GemFire AsyncEventQueue.
|
AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache,
com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener asyncEventListener)
Constructs an instance of the AsyncEventQueueFactoryBean for creating an GemFire AsyncEventQueue.
|
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
protected void |
doInit() |
com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue |
getObject() |
Class<?> |
getObjectType() |
boolean |
isParallelEventQueue() |
boolean |
isSerialEventQueue() |
void |
setAsyncEventListener(com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener listener) |
void |
setAsyncEventQueue(com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue asyncEventQueue) |
void |
setBatchConflationEnabled(Boolean batchConflationEnabled)
Enable or disable the Async Event Queue's (AEQ) should conflate messages.
|
void |
setBatchSize(Integer batchSize) |
void |
setBatchTimeInterval(Integer batchTimeInterval)
Set the Aysync Event Queue's (AEQ) interval between sending batches.
|
void |
setDiskStoreRef(String diskStoreRef) |
void |
setDiskSynchronous(Boolean diskSynchronous)
Set the Async Event Queue (AEQ) disk write synchronization policy.
|
void |
setDispatcherThreads(Integer dispatcherThreads)
Set the number of dispatcher threads used to process Region events from the associated Aysnc Event Queue (AEQ).
|
void |
setMaximumQueueMemory(Integer maximumQueueMemory) |
void |
setOrderPolicy(String orderPolicy)
Set the Async Event Queue (AEQ) ordering policy (e.g.
|
void |
setParallel(Boolean parallel) |
void |
setPersistent(Boolean persistent) |
afterPropertiesSet, getName, isSingleton, setBeanName, setFactory, setName
public AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache)
cache
- the GemFire Cache reference.AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache, com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener)
public AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache, com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener asyncEventListener)
cache
- the GemFire Cache reference.asyncEventListener
- required AsyncEventListener
public com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue getObject() throws Exception
getObject
in interface FactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
getObject
in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
Exception
public Class<?> getObjectType()
getObjectType
in interface FactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
getObjectType
in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
protected void doInit()
doInit
in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
public void destroy() throws Exception
destroy
in interface DisposableBean
destroy
in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
Exception
public final void setAsyncEventListener(com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener listener)
public void setDiskStoreRef(String diskStoreRef)
public void setBatchSize(Integer batchSize)
public void setMaximumQueueMemory(Integer maximumQueueMemory)
public void setPersistent(Boolean persistent)
public void setParallel(Boolean parallel)
public boolean isSerialEventQueue()
public boolean isParallelEventQueue()
public void setAsyncEventQueue(com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue asyncEventQueue)
asyncEventQueue
- overrides Async Event Queue returned by this FactoryBean.public void setDispatcherThreads(Integer dispatcherThreads)
dispatcherThreads
- an integer indicating the number of dispatcher threads used to process Region events
from the associated queue.public void setBatchTimeInterval(Integer batchTimeInterval)
batchTimeInterval
- an integer value indicating the maximum number of milliseconds that can elapse
between sending batches.public void setBatchConflationEnabled(Boolean batchConflationEnabled)
batchConflationEnabled
- a boolean value indicating whether to conflate queued events.public void setDiskSynchronous(Boolean diskSynchronous)
diskSynchronous
- a boolean value indicating whether disk writes are synchronous.public void setOrderPolicy(String orderPolicy)
orderPolicy
- a String to indicate the AEQ order policy.