PDA

View Full Version : AbstractMessageBarrierHandler Question



cmdunn01886
Nov 3rd, 2009, 03:42 PM
I have been looking through the AbstractMessageBarrierHandler.processMessage code trying to extend the
AbstractMessageAggregator and had a question about some code.
In the AbstractMessageBarrierHandler.processMessage it looks like if the message received is the one right after the complete (i.e, canAddMessage is false), the message gets dropped? I could be missing something, but is this true? If you can't add the message to the barrier here, should it be discarded?

Thanks,
Mike

iwein
Nov 4th, 2009, 01:58 AM
If you're going down this path you should check out:
http://jira.springframework.org/browse/INT-330?page=com.atlassian.jirafisheyeplugin%3Afisheye-issuepanel

I found extending AbstractMessageBarrierHandler too difficult, so I've come up with a replacement.

I've done the ground work for a new MessageStore backed component called BufferingMessageHandler I've used it to create replacements for the aggregator and resequencer.

There is no namespace support for it yet, but it's ready for a spin.