public class EventCorrelator extends Object implements Startable, Stoppable, Disposable
Modifier and Type | Field and Description |
---|---|
protected Object |
groupsLock |
protected long |
groupTimeToLive |
protected Log |
logger
logger used by this class
|
static String |
NO_CORRELATION_ID |
protected ObjectStore<Long> |
processedGroups |
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
EventCorrelator(EventCorrelatorCallback callback,
MessageProcessor timeoutMessageProcessor,
MessageInfoMapping messageInfoMapping,
MuleContext muleContext,
FlowConstruct flowConstruct,
PartitionableObjectStore correlatorStore,
String storePrefix,
ObjectStore<Long> processedGroups) |
Modifier and Type | Method and Description |
---|---|
protected EventGroup |
addEventGroup(EventGroup group) |
protected void |
addProcessedGroup(Object id) |
void |
dispose()
A lifecycle method where implementor should free up any resources.
|
void |
forceGroupExpiry(String groupId) |
protected EventGroup |
getEventGroup(Serializable groupId) |
protected String |
getEventGroupsPartitionKey() |
protected String |
getExpiredAndDispatchedPartitionKey() |
long |
getTimeout() |
protected void |
handleGroupExpiry(EventGroup group) |
boolean |
isFailOnTimeout() |
protected boolean |
isGroupAlreadyProcessed(Object id) |
MuleEvent |
process(MuleEvent event) |
protected void |
removeEventGroup(EventGroup group) |
void |
setFailOnTimeout(boolean failOnTimeout) |
void |
setTimeout(long timeout) |
void |
start() |
void |
stop() |
protected final transient Log logger
public static final String NO_CORRELATION_ID
protected long groupTimeToLive
protected final Object groupsLock
protected ObjectStore<Long> processedGroups
public EventCorrelator(EventCorrelatorCallback callback, MessageProcessor timeoutMessageProcessor, MessageInfoMapping messageInfoMapping, MuleContext muleContext, FlowConstruct flowConstruct, PartitionableObjectStore correlatorStore, String storePrefix, ObjectStore<Long> processedGroups)
public void forceGroupExpiry(String groupId) throws MessagingException
MessagingException
public MuleEvent process(MuleEvent event) throws RoutingException
RoutingException
protected EventGroup getEventGroup(Serializable groupId) throws ObjectStoreException
ObjectStoreException
protected EventGroup addEventGroup(EventGroup group) throws ObjectStoreException
ObjectStoreException
protected void removeEventGroup(EventGroup group) throws ObjectStoreException
ObjectStoreException
protected void addProcessedGroup(Object id) throws ObjectStoreException
ObjectStoreException
protected boolean isGroupAlreadyProcessed(Object id) throws ObjectStoreException
ObjectStoreException
public boolean isFailOnTimeout()
public void setFailOnTimeout(boolean failOnTimeout)
public long getTimeout()
public void setTimeout(long timeout)
protected void handleGroupExpiry(EventGroup group) throws MessagingException
MessagingException
public void start() throws MuleException
start
in interface Startable
MuleException
public void stop() throws MuleException
stop
in interface Stoppable
MuleException
protected String getExpiredAndDispatchedPartitionKey()
protected String getEventGroupsPartitionKey()
public void dispose()
Disposable
dispose
in interface Disposable
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.