Error handling (async) with splitter -> service activator -> aggregator
I'm looking for the correct way/pattern how to deal with errors in a service activator after a splitter.
I need to split up an XML-file for parallel processing by a task executor pool.
The successfully processed messages (they are sent to a remote system using rmi) need to be aggregated to an output file and I'd like to output errors (the ones rejected by the remote system) to a different file.
What is the preferred way to model this with Spring Integration?
Specifically, how do I deal with aggregation of the successes and the errors/exceptions?
I've looked in the reference manual and in the Apress book, but I can't seem to find a suggestion on how to deal with this use-case.
Thanks in advance!