org.iqual.chaplin.composite
Class AggregatorReceiver

java.lang.Object
  org.iqual.chaplin.composite.AggregatorReceiver

All Implemented Interfaces:

MessageReceiver

public class AggregatorReceiver
extends Object
implements MessageReceiver

This receiver handles aggregations in the composite. It is always inserted as the first receiver in the receiver chain.

Since:

Jun 12, 2009 9:19:04 PM

Author:

Zbynek Slajchrt

Constructor Summary

AggregatorReceiver()

Method Summary

ComponentAggregator	getComponentAggregator()
ReturnAggregator	getReturnAggregator()
boolean	isActive()
void	onMessageReceived(Message message, MessageReplies replies, MessageReceiversChain chain) Called when a request is made.
void	setComponentAggregator(ComponentAggregator componentAggregator)
void	setReturnAggregator(ReturnAggregator returnAggregator)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregatorReceiver

public AggregatorReceiver()

Method Detail

isActive

public boolean isActive()

onMessageReceived

public void onMessageReceived(Message message,
                              MessageReplies replies,
                              MessageReceiversChain chain)
                       throws Throwable

Description copied from interface: MessageReceiver

Called when a request is made. The receiver must call the chain's process method so that the subsequent receivers could be called. The receiver may manipulate with the arguments passed to that method. For example it may change the message that will be processed by the subsequent receivers in the chain or change the results of the subsequent message processing.

Specified by:

onMessageReceived in interface MessageReceiver

Throws:

Throwable

setReturnAggregator

public void setReturnAggregator(ReturnAggregator returnAggregator)

setComponentAggregator

public void setComponentAggregator(ComponentAggregator componentAggregator)

getReturnAggregator

public ReturnAggregator getReturnAggregator()

getComponentAggregator

public ComponentAggregator getComponentAggregator()