org.openspaces.archive

Class ArchivePollingContainerConfigurer

java.lang.Object

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

Constructors

Constructor and Description
ArchivePollingContainerConfigurer(GigaSpace gigaSpace)

Method Summary

Modifier and Type	Method and Description
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:

AbstractEventListenerContainer.setBeanName(String)

concurrentConsumers

public ArchivePollingContainerConfigurer concurrentConsumers(int concurrentConsumers)

See Also:

SimplePollingEventListenerContainer.setConcurrentConsumers(int)

template

public ArchivePollingContainerConfigurer template(Object template)

See Also:

AbstractEventListenerContainer.setTemplate(Object)

maxConcurrentConsumers

public ArchivePollingContainerConfigurer maxConcurrentConsumers(int maxConcurrentConsumers)

See Also:

SimplePollingEventListenerContainer.setMaxConcurrentConsumers(int)

receiveTimeout

public ArchivePollingContainerConfigurer receiveTimeout(long receiveTimeout)

See Also:

SimplePollingEventListenerContainer.setReceiveTimeout(long)

performSnapshot

public ArchivePollingContainerConfigurer performSnapshot(boolean performSnapshot)

See Also:

AbstractEventListenerContainer.setPerformSnapshot(boolean)

recoveryInterval

public ArchivePollingContainerConfigurer recoveryInterval(long recoveryInterval)

See Also:

SimplePollingEventListenerContainer.setRecoveryInterval(long)

autoStart

public ArchivePollingContainerConfigurer autoStart(boolean autoStart)

See Also:

AbstractEventListenerContainer.setAutoStart(boolean)

archiveHandler

public ArchivePollingContainerConfigurer archiveHandler(ArchiveOperationHandler archiveHandler)

See Also:

ArchivePollingContainer.setArchiveHandler(ArchiveOperationHandler)

transactionManager

public ArchivePollingContainerConfigurer transactionManager(PlatformTransactionManager transactionManager)

See Also:

AbstractEventListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)

transactionName

public ArchivePollingContainerConfigurer transactionName(String transactionName)

See Also:

AbstractEventListenerContainer.setTransactionName(String)

transactionTimeout

public ArchivePollingContainerConfigurer transactionTimeout(int transactionTimeout)

See Also:

AbstractEventListenerContainer.setTransactionTimeout(int)

transactionIsolationLevel

public ArchivePollingContainerConfigurer transactionIsolationLevel(int transactionIsolationLevel)

See Also:

AbstractEventListenerContainer.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)