org.jboss.soa.esb.actions.aggregator
Class StreamingAggregator

java.lang.Object
  org.jboss.soa.esb.actions.AbstractActionLifecycle
      org.jboss.soa.esb.actions.AbstractActionPipelineProcessor
          org.jboss.soa.esb.actions.aggregator.AbstractAggregator
              org.jboss.soa.esb.actions.aggregator.StreamingAggregator

All Implemented Interfaces:

ActionLifecycle, ActionPipelineProcessor

public class StreamingAggregator
extends AbstractAggregator

Concrete implementation of the AbstractAggregator class which stores te messages.

Author:

Kevin Conner

Field Summary

Fields inherited from interface org.jboss.soa.esb.actions.ActionPipelineProcessor

PROCESS_EXCEPTION_METHOD, PROCESS_METHOD, PROCESS_SUCCESS_METHOD

Constructor Summary

StreamingAggregator(ConfigTree config)

Method Summary

protected boolean

aggregateMessage(Message aggregatedMessage, java.lang.Integer messageSequence, Message currentMessage)

Methods inherited from class org.jboss.soa.esb.actions.aggregator.AbstractAggregator

destroy, initialise, process

Methods inherited from class org.jboss.soa.esb.actions.AbstractActionPipelineProcessor

processException, processSuccess

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingAggregator

public StreamingAggregator(ConfigTree config)
                    throws ConfigurationException

Throws:

ConfigurationException

Method Detail

aggregateMessage

protected boolean aggregateMessage(Message aggregatedMessage,
                                   java.lang.Integer messageSequence,
                                   Message currentMessage)
                            throws ActionProcessingException

Specified by:

aggregateMessage in class AbstractAggregator

Throws:

ActionProcessingException