org.adroitlogic.ultraesb.api.helper

Interface MessageAggregator

public interface MessageAggregator

Author:

asankha

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	MessageAggregator.AggregationConstants

Method Summary

Methods

Modifier and Type	Method and Description
void	aggregate(Message msg) Aggregate the current message according to configuration of the aggregator instance.
void	beginTimer(Message m) Begin timer to process expired messages for aggregated responses to this message

Method Detail

aggregate

void aggregate(Message msg)

Aggregate the current message according to configuration of the aggregator instance. Note that the current payload of the message will be detached and a reference to the Message kept

Parameters:

msg - the message to be aggregated

beginTimer

void beginTimer(Message m)

Begin timer to process expired messages for aggregated responses to this message

Parameters:

m - the original parent message (See sample # 212)