org.springframework.data.gemfire.wan
Class AsyncEventQueueFactoryBean

java.lang.Object
  extended by org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
      extended by org.springframework.data.gemfire.wan.AsyncEventQueueFactoryBean
All Implemented Interfaces:
Aware, BeanNameAware, DisposableBean, FactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>, InitializingBean

public class AsyncEventQueueFactoryBean
extends AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>

FactoryBean for creating GemFire AsyncEventQueues.


Field Summary
 
Fields inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean
cache, factory, log
 
Constructor Summary
AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache, com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener asyncEventListener)
           
 
Method Summary
 void destroy()
           
protected  void doInit()
           
 com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue getObject()
           
 Class<?> getObjectType()
           
 void setAsyncEventQueue(com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue asyncEventQueue)
           
 void setBatchConflationEnabled(Boolean batchConflationEnabled)
           
 void setBatchSize(Integer batchSize)
           
 void setBatchTimeInterval(Integer batchTimeInterval)
           
 void setDiskStoreRef(String diskStoreRef)
           
 void setDiskSynchronous(Boolean diskSynchronous)
           
 void setDispatcherThreads(Integer dispatcherThreads)
           
 void setMaximumQueueMemory(Integer maximumQueueMemory)
           
 void setOrderPolicy(String orderPolicy)
           
 void setParallel(Boolean parallel)
           
 void setPersistent(Boolean persistent)
           
static void setValidOrderPolicyValues(List<String> validOrderPolicyValues)
           
 
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

AsyncEventQueueFactoryBean

public AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache,
                                  com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener asyncEventListener)
Parameters:
cache - the gemfire cache
asyncEventListener - required AsyncEventListener
Method Detail

setDiskStoreRef

public void setDiskStoreRef(String diskStoreRef)

getObject

public com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue getObject()
                                                                throws Exception
Specified by:
getObject in interface FactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
Specified by:
getObject in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
Throws:
Exception

getObjectType

public Class<?> getObjectType()
Specified by:
getObjectType in interface FactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
Specified by:
getObjectType in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>

doInit

protected void doInit()
Specified by:
doInit in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>

destroy

public void destroy()
             throws Exception
Specified by:
destroy in interface DisposableBean
Overrides:
destroy in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
Throws:
Exception

setBatchSize

public void setBatchSize(Integer batchSize)

setMaximumQueueMemory

public void setMaximumQueueMemory(Integer maximumQueueMemory)

setPersistent

public void setPersistent(Boolean persistent)

setParallel

public void setParallel(Boolean parallel)

setValidOrderPolicyValues

public static void setValidOrderPolicyValues(List<String> validOrderPolicyValues)
Parameters:
validOrderPolicyValues - the validOrderPolicyValues to set

setAsyncEventQueue

public void setAsyncEventQueue(com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue asyncEventQueue)
Parameters:
asyncEventQueue - the asyncEventQueue to set

setDispatcherThreads

public void setDispatcherThreads(Integer dispatcherThreads)
Parameters:
dispatcherThreads - the dispatcherThreads to set

setBatchTimeInterval

public void setBatchTimeInterval(Integer batchTimeInterval)
Parameters:
batchTimeInterval -

setBatchConflationEnabled

public void setBatchConflationEnabled(Boolean batchConflationEnabled)
Parameters:
batchConflationEnabled -

setDiskSynchronous

public void setDiskSynchronous(Boolean diskSynchronous)
Parameters:
diskSynchronous -

setOrderPolicy

public void setOrderPolicy(String orderPolicy)
Parameters:
orderPolicy -