GigaSpaces XAP 9.7.2 API

org.openspaces.archive
Class ArchivePollingContainerConfigurer

java.lang.Object
  extended by org.openspaces.archive.ArchivePollingContainerConfigurer

public class ArchivePollingContainerConfigurer
extends Object

A configuration for ArchivePollingContainer using fluent API.

Sample usage of static template:

 UrlSpaceConfigurer urlSpaceConfigurerPrimary = new UrlSpaceConfigurer("/./space");
 GigaSpace gigaSpace = new GigaSpaceConfigurer(urlSpaceConfigurerPrimary.space()).gigaSpace();
 ArchivePollingEventListenerContainer archiveContainer = new ArchiveContainerConfigurer(gigaSpace)
              .template(new TestMessage())
              .archiveHandler(new CasandraArchiveOperationHandler())
              .create();

 ...

 archiveContainer.destroy();
 urlSpaceConfigurerPrimary.destroy();
 

Since:
9.1.1
Author:
Itai Frenkel

Constructor Summary
ArchivePollingContainerConfigurer(GigaSpace gigaSpace)
           
 
Method Summary
 ArchivePollingContainerConfigurer archiveHandler(ArchiveOperationHandler archiveHandler)
           
 ArchivePollingContainerConfigurer autoStart(boolean autoStart)
           
 ArchivePollingContainerConfigurer batchSize(int batchSize)
           
 ArchivePollingContainerConfigurer concurrentConsumers(int concurrentConsumers)
           
 ArchivePollingContainer create()
           
 ArchivePollingContainerConfigurer dynamicTemplate(DynamicEventTemplateProvider templateProvider)
           
 ArchivePollingContainerConfigurer dynamicTemplateAnnotation(Object templateProvider)
           
 ArchivePollingContainerConfigurer dynamicTemplateMethod(Object templateProvider, String methodName)
           
 ArchivePollingContainerConfigurer maxConcurrentConsumers(int maxConcurrentConsumers)
           
 ArchivePollingContainerConfigurer name(String name)
           
 ArchivePollingContainerConfigurer nonBlockingSleep(long nonBlockingSleepMilliseconds)
           
 ArchivePollingContainerConfigurer performSnapshot(boolean performSnapshot)
           
 ArchivePollingContainerConfigurer receiveTimeout(long receiveTimeout)
           
 ArchivePollingContainerConfigurer recoveryInterval(long recoveryInterval)
           
 ArchivePollingContainerConfigurer template(Object template)
           
 ArchivePollingContainerConfigurer transactionIsolationLevel(int transactionIsolationLevel)
           
 ArchivePollingContainerConfigurer transactionManager(PlatformTransactionManager transactionManager)
           
 ArchivePollingContainerConfigurer transactionName(String transactionName)
           
 ArchivePollingContainerConfigurer transactionTimeout(int transactionTimeout)
           
 ArchivePollingContainerConfigurer useFifoGrouping(boolean useFifoGrouping)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ArchivePollingContainerConfigurer

public ArchivePollingContainerConfigurer(GigaSpace gigaSpace)
Method Detail

name

public ArchivePollingContainerConfigurer name(String name)
See Also:
AbstractSpaceListeningContainer.setBeanName(String)

concurrentConsumers

public ArchivePollingContainerConfigurer concurrentConsumers(int concurrentConsumers)
See Also:
SimplePollingEventListenerContainer.setConcurrentConsumers(int)

template

public ArchivePollingContainerConfigurer template(Object template)
See Also:
AbstractTemplateEventListenerContainer.setTemplate(Object)

maxConcurrentConsumers

public ArchivePollingContainerConfigurer maxConcurrentConsumers(int maxConcurrentConsumers)
See Also:
SimplePollingEventListenerContainer.setMaxConcurrentConsumers(int)

receiveTimeout

public ArchivePollingContainerConfigurer receiveTimeout(long receiveTimeout)
See Also:
AbstractPollingEventListenerContainer.setReceiveTimeout(long)

performSnapshot

public ArchivePollingContainerConfigurer performSnapshot(boolean performSnapshot)
See Also:
AbstractTemplateEventListenerContainer.setPerformSnapshot(boolean)

recoveryInterval

public ArchivePollingContainerConfigurer recoveryInterval(long recoveryInterval)
See Also:
SimplePollingEventListenerContainer.setRecoveryInterval(long)

autoStart

public ArchivePollingContainerConfigurer autoStart(boolean autoStart)
See Also:
AbstractSpaceListeningContainer.setAutoStart(boolean)

archiveHandler

public ArchivePollingContainerConfigurer archiveHandler(ArchiveOperationHandler archiveHandler)
See Also:
ArchivePollingContainer.setArchiveHandler(ArchiveOperationHandler)

transactionManager

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

transactionName

public ArchivePollingContainerConfigurer transactionName(String transactionName)
See Also:
AbstractTransactionalEventListenerContainer.setTransactionName(String)

transactionTimeout

public ArchivePollingContainerConfigurer transactionTimeout(int transactionTimeout)
See Also:
AbstractTransactionalEventListenerContainer.setTransactionTimeout(int)

transactionIsolationLevel

public ArchivePollingContainerConfigurer transactionIsolationLevel(int transactionIsolationLevel)
See Also:
AbstractTransactionalEventListenerContainer.setTransactionIsolationLevel(int)

dynamicTemplate

public ArchivePollingContainerConfigurer dynamicTemplate(DynamicEventTemplateProvider templateProvider)
See Also:
org.openspaces.events.polling.SimplePollingEventListenerContainer#setTemplateProvider()

dynamicTemplateMethod

public ArchivePollingContainerConfigurer dynamicTemplateMethod(Object templateProvider,
                                                               String methodName)
See Also:
org.openspaces.events.adapter.MethodTemplateProviderAdapter

dynamicTemplateAnnotation

public ArchivePollingContainerConfigurer dynamicTemplateAnnotation(Object templateProvider)
See Also:
AnnotationDynamicEventTemplateProviderAdapter

create

public ArchivePollingContainer create()

batchSize

public ArchivePollingContainerConfigurer batchSize(int batchSize)
See Also:
ArchivePollingContainer.setBatchSize(int)

nonBlockingSleep

public ArchivePollingContainerConfigurer nonBlockingSleep(long nonBlockingSleepMilliseconds)
See Also:
ArchivePollingContainer.setNonBlockingSleep(long)

useFifoGrouping

public ArchivePollingContainerConfigurer useFifoGrouping(boolean useFifoGrouping)
See Also:
ArchivePollingContainer.setUseFifoGrouping(boolean)

GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.