-
Notifications
You must be signed in to change notification settings - Fork 12
ASR-15: Add Aggregator application starter #1
Conversation
…lude` * Add more properties classes from Spring Boot to the `spring-configuration-metadata-whitelist.properties`
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Clever work!!
That's all - all minor - I can make the changes on merge if you agree.
//tag::ref-doc[] | ||
= Aggregator Processor | ||
|
||
Use the `aggregator` application to combine batches of message to single one based on the correlation. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
to combine multiple messages into one, based on some correlation mechanism.
|
||
//tag::configuration-properties[] | ||
$$aggregator.correlation$$:: $$SpEL expression for correlation key$$ *($$String$$, default: `correlationId` header)* | ||
$$aggregator.release$$:: $$SpEL expression for release strategy$$ *($$String$$, default: `sequenceSize` header)* |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
default: group size == sequenceSize header.
$$aggregator.correlation$$:: $$SpEL expression for correlation key$$ *($$String$$, default: `correlationId` header)* | ||
$$aggregator.release$$:: $$SpEL expression for release strategy$$ *($$String$$, default: `sequenceSize` header)* | ||
$$aggregator.aggregation$$:: $$SpEL expression for aggregation strategy$$ *($$String$$, default: collection of payloads)* | ||
$$aggregator.groupTimeout$$:: $$SpEL expression for timeout to expiring uncompleted groups$$ *($$String$$, default: none)* |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
...for a timeout to expire uncompleted...
$$aggregator.messageStoreEntity$$:: $$Persistence message store entity: table prefix in RDBMS, collection name in MongoDb, etc$$ *($$String$$, default: none)* | ||
//end::configuration-properties[] | ||
|
||
By default `aggregator` processor uses: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
the aggregator
import com.gemstone.gemfire.cache.Region; | ||
|
||
/** | ||
* @author Artem Bilan |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
javadocs
@@ -0,0 +1,2 @@ | |||
org.springframework.boot.env.EnvironmentPostProcessor=\ | |||
org.springframework.cloud.stream.app.aggregator.ExcludeStoresAutoConfigurationEnvironmentPostProcessor |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
newline
Will address myself soon. |
|
No |
Doh... I added it somehow to the |
Merged as d7d0554 |
Fixes spring-attic/app-starters-release#15