@Configuration(proxyBeanMethods=false) @EnableConfigurationProperties(value=AggregatorFunctionProperties.class) public class AggregatorFunctionConfiguration extends Object
Modifier and Type | Class and Description |
---|---|
protected static class |
AggregatorFunctionConfiguration.MessageStoreAutoConfiguration |
Constructor and Description |
---|
AggregatorFunctionConfiguration() |
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.messaging.MessageChannel outputChannel) |
Function<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>,reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> |
aggregatorFunction(org.springframework.integration.channel.FluxMessageChannel inputChannel,
org.springframework.integration.channel.FluxMessageChannel outputChannel) |
org.springframework.integration.aggregator.CorrelationStrategy |
correlationStrategy() |
org.springframework.integration.channel.FluxMessageChannel |
inputChannel() |
org.springframework.integration.aggregator.MessageGroupProcessor |
messageGroupProcessor() |
org.springframework.integration.channel.FluxMessageChannel |
outputChannel() |
org.springframework.integration.aggregator.ReleaseStrategy |
releaseStrategy() |
@Bean public Function<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>,reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> aggregatorFunction(org.springframework.integration.channel.FluxMessageChannel inputChannel, org.springframework.integration.channel.FluxMessageChannel outputChannel)
@Bean public org.springframework.integration.channel.FluxMessageChannel inputChannel()
@Bean public org.springframework.integration.channel.FluxMessageChannel outputChannel()
@Bean @ServiceActivator(inputChannel="inputChannel") 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, @Qualifier(value="outputChannel") org.springframework.messaging.MessageChannel outputChannel)
@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. All rights reserved.