|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
org.springframework.data.gemfire.wan.AsyncEventQueueFactoryBean
public class AsyncEventQueueFactoryBean
FactoryBean for creating GemFire AsyncEventQueues.
| Field Summary |
|---|
| Fields inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean |
|---|
cache, factory, log, VALID_ORDER_POLICIES |
| Constructor Summary | |
|---|---|
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. |
|
| Method Summary | |
|---|---|
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)
|
| Methods inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean |
|---|
afterPropertiesSet, getName, isSingleton, setBeanName, setFactory, setName |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
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| Method Detail |
|---|
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>Exceptionpublic 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 DisposableBeandestroy in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>Exceptionpublic 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.
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||