Class | Description |
---|---|
AggregatingMessageProducer<S,T> | |
AggregatingSinkMessageProducer<S extends Message,T extends Message> | |
Aggregator<S,T> |
This aggregator is used to realize a given
AggregationPolicy . |
ArrayListAggregationPolicy<S> |
An aggregation policy that creates
ArrayList aggregates. |
IdentityAggregationPolicy<T extends Message> |
An aggregation policy that returns the original unmodified
message as the aggregate.
|
MappingAggregationPolicy<S,T extends Message> |
An aggregation policy that performs a simple map operation
on the given message.
|
SinkAggregator<S extends Message,T extends Message> |
This is a specific aggregator where the messsages implement
the
Message marker interface. |
Copyright © 2020. All rights reserved.