Hi,
I am trying to implement a protocol (called ATS-M), which splits
messages for transportation and aggregates on receiving.
When the receiver gets correct segments, it returns response messages.
The sender waits for these response messages.
So it works asynchronously cause the sender cannot wait for a response
before sending another segment.
To use this implementation as a library it is implemented in a camel
context component.
The sender has to wait for responses and if no response is received it
has to react after a given timeout time.
So I tried to implement this behaviour in a camel route using an
aggregator waiting for a response message.
When a timeout occured, I tried to throw an exception, but this is not
propagated out of the aggregation.
Then I tried to use a synchronization in the SendController before the
Aggregator using onComplete() and onFailure().
But Camel just says "Exception occurred during onCompletion. This
exception will be ignored."
So how can I propagate an exception for a timeout back to the caller
route over the incoming endpoint of my context component?
Thanks,
Sven