This module provides an aggregation function that can be reused and composed in other applications.
You can import the AggregatorFunctionConfiguration
in a Spring Boot application and then inject the following bean.
aggregatorFunction
You can use aggregatorFunction
as a qualifier when injecting.
Once injected, you can use the apply
method of the Function
to invoke it and get the result.
For more information on the various options available, please see AggregatorFunctionProperties.java
A ComponentCustomizer<AggregatorFactoryBean>
bean can be added in the target project to provide any custom options for the AggregatorFactoryBean
configuration used by the aggregatorFunction
definition.
See this test suite for examples of how this function is used.
See this README where this function is used to create a Spring Cloud Stream application.