Package org.openspaces.events.polling
Class SimplePollingContainerConfigurer
java.lang.Object
org.openspaces.events.polling.SimplePollingContainerConfigurer
A simplified programmatic configuration that for
SimplePollingEventListenerContainer.
Sample usage:
UrlSpaceConfigurer urlSpaceConfigurerPrimary = new UrlSpaceConfigurer("/./space");
GigaSpace gigaSpace = new GigaSpaceConfigurer(urlSpaceConfigurerPrimary.space()).gigaSpace();
SimplePollingEventListenerContainer pollingEventListenerContainer = new
SimplePollingContainerConfigurer(gigaSpace)
.template(new TestMessage())
.eventListenerAnnotation(new Object() {
@SpaceDataEvent public void gotMeselfAnEvent() {
// do something
}
}).notifyContainer();
...
pollingEventListenerContainer.destroy();
urlSpaceConfigurerPrimary.destroy();
- Author:
- kimchy
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionactiveWhenPrimary(boolean activeWhenPrimary) autoStart(boolean autoStart) concurrentConsumers(int concurrentConsumers) create()Creates a newSimplePollingEventListenerContainerinstance.dynamicTemplate(DynamicEventTemplateProvider templateProvider) dynamicTemplateAnnotation(Object templateProvider) dynamicTemplateMethod(Object templateProvider, String methodName) eventListener(SpaceDataEventListener eventListener) eventListenerAnnotation(Object eventListener) Sets an event listener that uses annotationseventListenerMethod(Object eventListener, String methodName) Sets an event listener that uses method name as an adapterexceptionHandler(EventExceptionHandler exceptionHandler) idleTaskExecutionLimit(int idleTaskExecutionLimit) keepAliveRetries(int keepAliveRetries) maxConcurrentConsumers(int maxConcurrentConsumers) maxEventsPerTask(int maxEventsPerTask) passArrayAsIs(boolean passArrayAsIs) performSnapshot(boolean performSnapshot) Creates a newSimplePollingEventListenerContainerinstance.receiveOperationHandler(ReceiveOperationHandler receiveOperationHandler) receiveTimeout(long receiveTimeout) recoveryInterval(long recoveryInterval) taskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) transactionIsolationLevel(int transactionIsolationLevel) transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) transactionName(String transactionName) transactionTimeout(int transactionTimeout) triggerOperationHandler(TriggerOperationHandler triggerOperationHandler)
-
Constructor Details
-
SimplePollingContainerConfigurer
-
-
Method Details
-
name
-
taskExecutor
public SimplePollingContainerConfigurer taskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) -
recoveryInterval
-
concurrentConsumers
-
maxConcurrentConsumers
-
maxEventsPerTask
-
idleTaskExecutionLimit
-
passArrayAsIs
-
receiveTimeout
-
receiveOperationHandler
public SimplePollingContainerConfigurer receiveOperationHandler(ReceiveOperationHandler receiveOperationHandler) -
triggerOperationHandler
public SimplePollingContainerConfigurer triggerOperationHandler(TriggerOperationHandler triggerOperationHandler) -
template
-
performSnapshot
-
transactionManager
public SimplePollingContainerConfigurer transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) -
transactionName
-
transactionTimeout
-
transactionIsolationLevel
-
exceptionHandler
-
eventListener
-
eventListenerAnnotation
Sets an event listener that uses annotations -
eventListenerMethod
public SimplePollingContainerConfigurer eventListenerMethod(Object eventListener, String methodName) Sets an event listener that uses method name as an adapter -
activeWhenPrimary
-
autoStart
-
dynamicTemplate
public SimplePollingContainerConfigurer dynamicTemplate(DynamicEventTemplateProvider templateProvider) -
dynamicTemplateMethod
public SimplePollingContainerConfigurer dynamicTemplateMethod(Object templateProvider, String methodName) -
dynamicTemplateAnnotation
-
keepAliveRetries
-
create
Creates a newSimplePollingEventListenerContainerinstance. -
pollingContainer
Creates a newSimplePollingEventListenerContainerinstance.- See Also:
-