The Aggregator is a special filter (in a Pipes and Filters [70] architecture) that receives a stream of messages and identifies messages that are correlated. Once a complete set of messages has been received (more later on how to decide when a set is complete), the Aggregator collects information from each correlated message and publishes a single, aggregated message to the output channel for further processing.
