org.openspaces.events.polling
Class SimplePollingContainerConfigurer

java.lang.Object
  org.openspaces.events.polling.SimplePollingContainerConfigurer

public class SimplePollingContainerConfigurer
extends Object

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() {




Author:
  
kimchy








Constructor Summary
SimplePollingContainerConfigurer(GigaSpace gigaSpace)



           
 



Method Summary




 SimplePollingContainerConfigurer
activeWhenPrimary(boolean activeWhenPrimary)



           



 SimplePollingContainerConfigurer
autoStart(boolean autoStart)



           



 SimplePollingContainerConfigurer
concurrentConsumers(int concurrentConsumers)



           



 SimplePollingContainerConfigurer
eventListener(SpaceDataEventListener eventListener)



           



 SimplePollingContainerConfigurer
eventListenerAnnotation(Object eventListener)



          Sets an event listener that uses annotations



 SimplePollingContainerConfigurer
eventListenerMethod(Object eventListener,
                    String methodName)



          Sets an event listener that uses method name as an adapter



 SimplePollingContainerConfigurer
idleTaskExecutionLimit(int idleTaskExecutionLimit)



           



 SimplePollingContainerConfigurer
maxConcurrentConsumers(int maxConcurrentConsumers)



           



 SimplePollingContainerConfigurer
maxEventsPerTask(int maxEventsPerTask)



           



 SimplePollingContainerConfigurer
name(String name)



           



 SimplePollingContainerConfigurer
passArrayAsIs(boolean passArrayAsIs)



           



 SimplePollingContainerConfigurer
performSnapshot(boolean performSnapshot)



           



 SimplePollingEventListenerContainer
pollingContainer()



           



 SimplePollingContainerConfigurer
receiveOperationHandler(ReceiveOperationHandler receiveOperationHandler)



           



 SimplePollingContainerConfigurer
receiveTimeout(long receiveTimeout)



           



 SimplePollingContainerConfigurer
recoveryInterval(long recoveryInterval)



           



 SimplePollingContainerConfigurer
taskExecutor(TaskExecutor taskExecutor)



           



 SimplePollingContainerConfigurer
template(Object template)



           



 SimplePollingContainerConfigurer
transactionIsolationLevel(int transactionIsolationLevel)



           



 SimplePollingContainerConfigurer
transactionManager(PlatformTransactionManager transactionManager)



           



 SimplePollingContainerConfigurer
transactionName(String transactionName)



           



 SimplePollingContainerConfigurer
transactionTimeout(int transactionTimeout)



           



 SimplePollingContainerConfigurer
triggerOperationHandler(TriggerOperationHandler triggerOperationHandler)



           


 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 





Constructor Detail



SimplePollingContainerConfigurer
public SimplePollingContainerConfigurer(GigaSpace gigaSpace)






Method Detail



name
public SimplePollingContainerConfigurer name(String name)








taskExecutor
public SimplePollingContainerConfigurer taskExecutor(TaskExecutor taskExecutor)


See Also:
SimplePollingEventListenerContainer.setTaskExecutor(org.springframework.core.task.TaskExecutor)





recoveryInterval
public SimplePollingContainerConfigurer recoveryInterval(long recoveryInterval)


See Also:
SimplePollingEventListenerContainer.setRecoveryInterval(long)





concurrentConsumers
public SimplePollingContainerConfigurer concurrentConsumers(int concurrentConsumers)


See Also:
SimplePollingEventListenerContainer.setConcurrentConsumers(int)





maxConcurrentConsumers
public SimplePollingContainerConfigurer maxConcurrentConsumers(int maxConcurrentConsumers)


See Also:
SimplePollingEventListenerContainer.setMaxConcurrentConsumers(int)





maxEventsPerTask
public SimplePollingContainerConfigurer maxEventsPerTask(int maxEventsPerTask)


See Also:
SimplePollingEventListenerContainer.setMaxEventsPerTask(int)





idleTaskExecutionLimit
public SimplePollingContainerConfigurer idleTaskExecutionLimit(int idleTaskExecutionLimit)


See Also:
SimplePollingEventListenerContainer.setIdleTaskExecutionLimit(int)





passArrayAsIs
public SimplePollingContainerConfigurer passArrayAsIs(boolean passArrayAsIs)


See Also:
AbstractPollingEventListenerContainer.setPassArrayAsIs(boolean)





receiveTimeout
public SimplePollingContainerConfigurer receiveTimeout(long receiveTimeout)


See Also:
AbstractPollingEventListenerContainer.setReceiveTimeout(long)





receiveOperationHandler
public SimplePollingContainerConfigurer receiveOperationHandler(ReceiveOperationHandler receiveOperationHandler)


See Also:
AbstractPollingEventListenerContainer.setReceiveOperationHandler(org.openspaces.events.polling.receive.ReceiveOperationHandler)





triggerOperationHandler
public SimplePollingContainerConfigurer triggerOperationHandler(TriggerOperationHandler triggerOperationHandler)


See Also:
AbstractPollingEventListenerContainer.setTriggerOperationHandler(org.openspaces.events.polling.trigger.TriggerOperationHandler)





template
public SimplePollingContainerConfigurer template(Object template)


See Also:
AbstractTemplateEventListenerContainer.setTemplate(Object)





performSnapshot
public SimplePollingContainerConfigurer performSnapshot(boolean performSnapshot)


See Also:
AbstractTemplateEventListenerContainer.setPerformSnapshot(boolean)





transactionManager
public SimplePollingContainerConfigurer transactionManager(PlatformTransactionManager transactionManager)


See Also:
AbstractTransactionalEventListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)





transactionName
public SimplePollingContainerConfigurer transactionName(String transactionName)


See Also:
AbstractTransactionalEventListenerContainer.setTransactionName(String)





transactionTimeout
public SimplePollingContainerConfigurer transactionTimeout(int transactionTimeout)


See Also:
AbstractTransactionalEventListenerContainer.setTransactionTimeout(int)





transactionIsolationLevel
public SimplePollingContainerConfigurer transactionIsolationLevel(int transactionIsolationLevel)


See Also:
AbstractTransactionalEventListenerContainer.setTransactionIsolationLevel(int)





eventListener
public SimplePollingContainerConfigurer eventListener(SpaceDataEventListener eventListener)


See Also:
AbstractEventListenerContainer.setEventListener(org.openspaces.events.SpaceDataEventListener)





eventListenerAnnotation
public SimplePollingContainerConfigurer eventListenerAnnotation(Object eventListener)

Sets an event listener that uses annotations


See Also:
AbstractEventListenerContainer.setEventListener(org.openspaces.events.SpaceDataEventListener), 
AnnotationEventListenerAdapter





eventListenerMethod
public SimplePollingContainerConfigurer eventListenerMethod(Object eventListener,
                                                            String methodName)

Sets an event listener that uses method name as an adapter


See Also:
AbstractEventListenerContainer.setEventListener(org.openspaces.events.SpaceDataEventListener), 
MethodEventListenerAdapter





activeWhenPrimary
public SimplePollingContainerConfigurer activeWhenPrimary(boolean activeWhenPrimary)


See Also:
AbstractSpaceListeningContainer.setActiveWhenPrimary(boolean)





autoStart
public SimplePollingContainerConfigurer autoStart(boolean autoStart)


See Also:
AbstractSpaceListeningContainer.setAutoStart(boolean)





pollingContainer
public SimplePollingEventListenerContainer pollingContainer()