I would like to extend AbstractMessageAggregator (which extends AbstractMessageBarrierHandler), so I can flush the messages when my processing is complete.
What is the best way to configure this? If I configure it through the configuration file, it doesn't appear to work correctly. It appears i creates a MethodInvokingAggregator and invokes my methods, but doesn't create my class as a subclass of AbstractMessageAggregator. I say this because the barriers member of AbstractMessageBarrierHandler is always empty.
Do I need to start the Aggregator as a bean and start it manually?
Any help would be greatly appreciated.
Thanks in advance,