org.mule.routing

Class EventCorrelator

java.lang.Object

org.mule.routing.EventCorrelator

public class EventCorrelator
extends Object

TODO

Field Summary

Fields

Modifier and Type	Field and Description
protected edu.emory.mathcs.backport.java.util.concurrent.ConcurrentMap	eventGroups A map of EventGroup objects.
protected edu.emory.mathcs.backport.java.util.concurrent.ConcurrentMap	locks A map of locks used to wait for response messages for a given message id
protected org.apache.commons.logging.Log	logger logger used by this class
static int	MAX_PROCESSED_GROUPS
static String	NO_CORRELATION_ID
protected org.apache.commons.collections.buffer.BoundedFifoBuffer	processedGroups
protected edu.emory.mathcs.backport.java.util.concurrent.ConcurrentMap	responseMessages The collection of messages that are ready to be returned to the callee.

Constructor Summary

Constructors

Constructor and Description
EventCorrelator(EventCorrelatorCallback callback, MessageInfoMapping messageInfoMapping, MuleContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	addEvent(MuleEvent event)
protected EventGroup	addEventGroup(EventGroup group)
protected void	addProcessedGroup(Object id)
void	enableTimeoutMonitor()
protected EventGroup	getEventGroup(Object groupId)
MuleMessage	getResponse(MuleMessage message) This method is called by the responding callee thread and should return the aggregated response message
MuleMessage	getResponse(MuleMessage message, int timeout) This method is called by the responding callee thread and should return the aggregated response message
Map	getResponseMessages() Deprecated. this is used by a test, but I would like to remove this method
int	getTimeout()
boolean	isFailOnTimeout()
protected boolean	isGroupAlreadyProcessed(Object id)
MuleMessage	process(MuleEvent event)
protected void	removeEventGroup(EventGroup group)
void	setFailOnTimeout(boolean failOnTimeout)
void	setTimeout(int timeout)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final transient org.apache.commons.logging.Log logger

logger used by this class

NO_CORRELATION_ID

public static final String NO_CORRELATION_ID

See Also:

Constant Field Values

MAX_PROCESSED_GROUPS

public static final int MAX_PROCESSED_GROUPS

See Also:

Constant Field Values

eventGroups

protected final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentMap eventGroups

A map of EventGroup objects. These represent one or more messages to be agregated, keyed by message id. There will be one response message for every EventGroup.

locks

protected final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentMap locks

A map of locks used to wait for response messages for a given message id

responseMessages

protected final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentMap responseMessages

The collection of messages that are ready to be returned to the callee. Keyed by Message ID

processedGroups

protected final org.apache.commons.collections.buffer.BoundedFifoBuffer processedGroups

Constructor Detail

EventCorrelator

public EventCorrelator(EventCorrelatorCallback callback,
               MessageInfoMapping messageInfoMapping,
               MuleContext context)

Method Detail

enableTimeoutMonitor

public void enableTimeoutMonitor()
                          throws javax.resource.spi.work.WorkException

Throws:

javax.resource.spi.work.WorkException

getResponseMessages

public Map getResponseMessages()

Deprecated. this is used by a test, but I would like to remove this method

Returns:

process

public MuleMessage process(MuleEvent event)
                    throws RoutingException

Throws:

RoutingException

addEvent

public void addEvent(MuleEvent event)
              throws RoutingException

Throws:

RoutingException

getEventGroup

protected EventGroup getEventGroup(Object groupId)

See Also:

org.mule.routing.inbound.AbstractEventAggregator#getEventGroup(Object)

addEventGroup

protected EventGroup addEventGroup(EventGroup group)

See Also:

org.mule.routing.inbound.AbstractEventAggregator#addEventGroup(EventGroup)

removeEventGroup

protected void removeEventGroup(EventGroup group)

See Also:

org.mule.routing.inbound.AbstractEventAggregator#removeEventGroup(EventGroup)

addProcessedGroup

protected void addProcessedGroup(Object id)

isGroupAlreadyProcessed

protected boolean isGroupAlreadyProcessed(Object id)

getResponse

public MuleMessage getResponse(MuleMessage message)
                        throws RoutingException

This method is called by the responding callee thread and should return the aggregated response message

Parameters:

message -

Returns:

Throws:

RoutingException

getResponse

public MuleMessage getResponse(MuleMessage message,
                      int timeout)
                        throws RoutingException

This method is called by the responding callee thread and should return the aggregated response message

Parameters:

message -

Returns:

Throws:

RoutingException

isFailOnTimeout

public boolean isFailOnTimeout()

setFailOnTimeout

public void setFailOnTimeout(boolean failOnTimeout)

getTimeout

public int getTimeout()

setTimeout

public void setTimeout(int timeout)