Package org.springframework.cloud.fn.aggregator

Class AggregatorFunctionConfiguration

java.lang.Object
org.springframework.cloud.fn.aggregator.AggregatorFunctionConfiguration
@AutoConfiguration @EnableConfigurationProperties(AggregatorFunctionProperties.class) public class AggregatorFunctionConfiguration extends Object
Author:
Artem Bilan, Corneil du Plessis

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    protected static class 
    AggregatorFunctionConfiguration.MessageStoreAutoConfiguration
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AggregatorFunctionConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.integration.config.AggregatorFactoryBean
    aggregator(org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy, org.springframework.integration.aggregator.ReleaseStrategy releaseStrategy, org.springframework.integration.aggregator.MessageGroupProcessor messageGroupProcessor, org.springframework.integration.store.MessageGroupStore messageStore, MessageChannel outputChannel, org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.config.AggregatorFactoryBean> aggregatorCustomizer)
     
    Function<reactor.core.publisher.Flux<Message<?>>,reactor.core.publisher.Flux<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()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • AggregatorFunctionConfiguration

      public AggregatorFunctionConfiguration()

  • Method Details

    • aggregatorFunction

      @Bean public Function<reactor.core.publisher.Flux<Message<?>>,reactor.core.publisher.Flux<Message<?>>> aggregatorFunction(org.springframework.integration.channel.FluxMessageChannel inputChannel, org.springframework.integration.channel.FluxMessageChannel outputChannel)

    • inputChannel

      @Bean public org.springframework.integration.channel.FluxMessageChannel inputChannel()

    • outputChannel

      @Bean public org.springframework.integration.channel.FluxMessageChannel outputChannel()

    • aggregator

      @Bean @ServiceActivator(inputChannel="inputChannel") public org.springframework.integration.config.AggregatorFactoryBean aggregator(@Nullable org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy, @Nullable org.springframework.integration.aggregator.ReleaseStrategy releaseStrategy, @Nullable org.springframework.integration.aggregator.MessageGroupProcessor messageGroupProcessor, @Nullable org.springframework.integration.store.MessageGroupStore messageStore, @Qualifier("outputChannel") MessageChannel outputChannel, @Nullable org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.config.AggregatorFactoryBean> aggregatorCustomizer)

    • correlationStrategy

      @Bean @ConditionalOnProperty(prefix="aggregator", name="correlation") @ConditionalOnMissingBean public org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy()

    • releaseStrategy

      @Bean @ConditionalOnProperty(prefix="aggregator", name="release") @ConditionalOnMissingBean public org.springframework.integration.aggregator.ReleaseStrategy releaseStrategy()

    • messageGroupProcessor

      @Bean @ConditionalOnProperty(prefix="aggregator", name="aggregation") @ConditionalOnMissingBean public org.springframework.integration.aggregator.MessageGroupProcessor messageGroupProcessor()