@EnableBinding(value=org.springframework.cloud.stream.messaging.Processor.class) @EnableConfigurationProperties(value=AggregatorProperties.class) public class AggregatorProcessorConfiguration extends Object
Modifier and Type | Class and Description |
---|---|
protected static class |
AggregatorProcessorConfiguration.MessageStoreAutoConfiguration |
Constructor and Description |
---|
AggregatorProcessorConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.config.AggregatorFactoryBean |
aggregator(org.springframework.beans.factory.ObjectProvider<org.springframework.integration.aggregator.CorrelationStrategy> correlationStrategy,
org.springframework.beans.factory.ObjectProvider<org.springframework.integration.aggregator.ReleaseStrategy> releaseStrategy,
org.springframework.beans.factory.ObjectProvider<org.springframework.integration.aggregator.MessageGroupProcessor> messageGroupProcessor,
org.springframework.beans.factory.ObjectProvider<org.springframework.integration.store.MessageGroupStore> messageStore) |
org.springframework.integration.aggregator.CorrelationStrategy |
correlationStrategy() |
org.springframework.integration.aggregator.MessageGroupProcessor |
messageGroupProcessor() |
org.springframework.integration.aggregator.ReleaseStrategy |
releaseStrategy() |
@Bean @ServiceActivator(inputChannel="input") public org.springframework.integration.config.AggregatorFactoryBean aggregator(org.springframework.beans.factory.ObjectProvider<org.springframework.integration.aggregator.CorrelationStrategy> correlationStrategy, org.springframework.beans.factory.ObjectProvider<org.springframework.integration.aggregator.ReleaseStrategy> releaseStrategy, org.springframework.beans.factory.ObjectProvider<org.springframework.integration.aggregator.MessageGroupProcessor> messageGroupProcessor, org.springframework.beans.factory.ObjectProvider<org.springframework.integration.store.MessageGroupStore> messageStore)
@Bean @ConditionalOnProperty(prefix="aggregator", name="correlation") @ConditionalOnMissingBean public org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy()
@Bean @ConditionalOnProperty(prefix="aggregator", name="release") @ConditionalOnMissingBean public org.springframework.integration.aggregator.ReleaseStrategy releaseStrategy()
@Bean @ConditionalOnProperty(prefix="aggregator", name="aggregation") @ConditionalOnMissingBean public org.springframework.integration.aggregator.MessageGroupProcessor messageGroupProcessor()
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.