Enterprise Integration Patterns - Aggregate
Overview
The purpose of the aggregate pattern is to take a set of one or more input messages and create a single output message.
Use Cases
Aggregate can be used to satisfy a wide range of use cases depending on the message type and message flow requirements. The following use cases represent the most common categories for using aggregate.
Reassembly
Take a set of related messages and cram them into a single message. Most commonly used in conjunction with split and broadcast, where the number of messages in the input set is known.
Batching
Hold a bunch of messages and release them as a single batch message. The determination of when to release the batch message can be based on a time window, number of messages, size of messages, etc.
Enveloping
A refinement of batching, an enveloping aggregate can be used to create a group of messages with common characteristics (same type, same destination, same source, etc.). These messages are wrapped in one or more envelopes before they are forwarded as a single message.
Gating
An aggregate which can be used to make sure that messages from different flows are held until all messages arrive at the aggregate.
IFL
Configuration
Packaging
At application build time, all aggregate configurations should be packaged as part of the application. Since the ultimate consumer of this configuration information is the runtime aggregate implementation, and not a component, it is not appropriate to package the individual configuration instances into a service unit. Rather, the following convention should be followed:
app-root /
META-INF /
flow/
aggregate/
[configuration]
Where '{name}' is the named configuration provided in IFL. This layout mimics the configuration layout, but includes META-INF/ and flow/ as parent directories.
All aggregate configuration should be included in this directory, including inline configuration. Since inline configuration is not named, a name must be generated. Using a pattern of 'aggregate$n' should work, where 'n > 0' and increments for each inline aggregate definition in the IFL.
Runtime
This page (revision-3) was last changed on
20-Aug-08 16:33 PM, -0700
by KeithBabo.
This page was created on
20-Aug-08 12:38 PM, -0700 by KeithBabo.
More info...
| Version |
Date |
Author |
Size |
Changes ... |
|
16
|
02-Jun-09 02:04 AM, -0700
|
Nikita |
4258 |
to previous
|
|
15
|
06-May-09 09:10 AM, -0700
|
Nikita |
6084 |
to previous
|
to last
|
|
14
|
24-Oct-08 09:43 AM, -0700
|
Mark Saunders |
6081 |
to previous
|
to last
|
|
13
|
26-Sep-08 05:59 AM, -0700
|
KeithBabo |
5988 |
to previous
|
to last
|
|
12
|
22-Sep-08 16:51 PM, -0700
|
KeithBabo |
5986 |
to previous
|
to last
|
|
11
|
22-Sep-08 12:54 PM, -0700
|
KeithBabo |
5987 |
to previous
|
to last
|
|
10
|
22-Sep-08 07:57 AM, -0700
|
KeithBabo |
5766 |
to previous
|
to last
|
|
9
|
22-Sep-08 07:55 AM, -0700
|
KeithBabo |
5984 |
to previous
|
to last
|
|
8
|
22-Sep-08 07:54 AM, -0700
|
KeithBabo |
5964 |
to previous
|
to last
|
|
7
|
22-Sep-08 07:48 AM, -0700
|
KeithBabo |
5337 |
to previous
|
to last
|
|
6
|
22-Sep-08 07:18 AM, -0700
|
KeithBabo |
4502 |
to previous
|
to last
|
|
5
|
21-Aug-08 09:35 AM, -0700
|
KeithBabo |
2958 |
to previous
|
to last
|
|
4
|
20-Aug-08 16:57 PM, -0700
|
KeithBabo |
2501 |
to previous
|
to last
|
|
3
|
20-Aug-08 16:33 PM, -0700
|
KeithBabo |
2406 |
to previous
|
to last
|
|
2
|
20-Aug-08 14:06 PM, -0700
|
KeithBabo |
1199 |
to previous
|
to last
|
|
1
|
20-Aug-08 12:38 PM, -0700
|
KeithBabo |
1116 |
to last
|