public class ArchivePollingContainerConfigurer extends Object
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();
| Constructor and Description |
|---|
ArchivePollingContainerConfigurer(GigaSpace gigaSpace) |
public ArchivePollingContainerConfigurer(GigaSpace gigaSpace)
public ArchivePollingContainerConfigurer name(String name)
public ArchivePollingContainerConfigurer concurrentConsumers(int concurrentConsumers)
public ArchivePollingContainerConfigurer template(Object template)
public ArchivePollingContainerConfigurer maxConcurrentConsumers(int maxConcurrentConsumers)
public ArchivePollingContainerConfigurer receiveTimeout(long receiveTimeout)
public ArchivePollingContainerConfigurer performSnapshot(boolean performSnapshot)
public ArchivePollingContainerConfigurer recoveryInterval(long recoveryInterval)
public ArchivePollingContainerConfigurer autoStart(boolean autoStart)
public ArchivePollingContainerConfigurer archiveHandler(ArchiveOperationHandler archiveHandler)
public ArchivePollingContainerConfigurer transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public ArchivePollingContainerConfigurer transactionName(String transactionName)
public ArchivePollingContainerConfigurer transactionTimeout(int transactionTimeout)
public ArchivePollingContainerConfigurer transactionIsolationLevel(int transactionIsolationLevel)
public ArchivePollingContainerConfigurer dynamicTemplate(DynamicEventTemplateProvider templateProvider)
public ArchivePollingContainerConfigurer dynamicTemplateMethod(Object templateProvider, String methodName)
public ArchivePollingContainerConfigurer dynamicTemplateAnnotation(Object templateProvider)
public ArchivePollingContainer create()
public ArchivePollingContainerConfigurer batchSize(int batchSize)
public ArchivePollingContainerConfigurer nonBlockingSleep(long nonBlockingSleepMilliseconds)
public ArchivePollingContainerConfigurer useFifoGrouping(boolean useFifoGrouping)
Copyright © GigaSpaces.