org.springframework.data.gemfire.wan
Class AsyncEventQueueFactoryBean
java.lang.Object
org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue>
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 AsyncEventQueue
s.
Constructor Summary |
AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache,
com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener asyncEventListener)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AsyncEventQueueFactoryBean
public AsyncEventQueueFactoryBean(com.gemstone.gemfire.cache.Cache cache,
com.gemstone.gemfire.cache.asyncqueue.AsyncEventListener asyncEventListener)
- Parameters:
cache
- the gemfire cacheasyncEventListener
- required AsyncEventListener
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)