THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||
|---|---|---|
| ||
...
from(...)
.aggregate()
.correlationExpression(header(id))
.aggregationStrategy(myStrategy)
.completionTimeout(10000)
.messageStore(myStore)
...
|
| Code Block | ||
|---|---|---|
| ||
defaultMessageStore(myStore);
|
| Code Block | ||
|---|---|---|
| ||
// 1) Store body.
// 2) Set body to null.
// 3) Set Exchange.CLAIM_CHECK header to unique claim id.
from(...).claimCheck().to(...);
|
| Code Block | ||
|---|---|---|
| ||
// 1) Lookup for the Exchange.CLAIM_CHECK header value.
// 2) Read the message.
// 3) Set body to the value fetched from the store.
from(...).setHeader(Exchange.CLAIM_CHECK, const("id")).claim().to(...);
|