Package org.operaton.bpm.engine.impl.runtime

Class DefaultCorrelationHandler

java.lang.Object

org.operaton.bpm.engine.impl.runtime.DefaultCorrelationHandler

All Implemented Interfaces:

CorrelationHandler

public class DefaultCorrelationHandler
extends Object
implements CorrelationHandler

Author:

Thorben Lindhauer, Daniel Meyer, Michael Scholz

Constructor Summary

Constructors

Constructor	Description
DefaultCorrelationHandler()

Method Summary

Modifier and Type	Method	Description
CorrelationHandlerResult	correlateMessage(CommandContext commandContext, String messageName, CorrelationSet correlationSet)	Correlate the given message to either a waiting execution or a process definition with a message start event.
List<CorrelationHandlerResult>	correlateMessages(CommandContext commandContext, String messageName, CorrelationSet correlationSet)	Correlate the given message to all waiting executions and all process definitions which have a message start event.
protected List<CorrelationHandlerResult>	correlateMessageToExecutions(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
protected List<CorrelationHandlerResult>	correlateStartMessageByEventSubscription(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
protected CorrelationHandlerResult	correlateStartMessageByProcessDefinitionId(CommandContext commandContext, String messageName, String processDefinitionId)
List<CorrelationHandlerResult>	correlateStartMessages(CommandContext commandContext, String messageName, CorrelationSet correlationSet)	Correlate the given message to process definitions with a message start event.
protected List<EventSubscriptionEntity>	findMessageStartEventSubscriptions(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
protected String	findStartActivityIdByMessage(ProcessDefinitionEntity processDefinition, String messageName)
protected boolean	isMessageStartEventWithName(EventSubscriptionDeclaration declaration, String messageName)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultCorrelationHandler

public DefaultCorrelationHandler()

Method Details

correlateMessage

public CorrelationHandlerResult correlateMessage(CommandContext commandContext,
 String messageName,
 CorrelationSet correlationSet)

Description copied from interface: CorrelationHandler

Correlate the given message to either a waiting execution or a process definition with a message start event.

Specified by:

correlateMessage in interface CorrelationHandler

Parameters:

correlationSet - any of its members may be null

Returns:

the matched correlation target or null if the message could not be correlated.

correlateMessages

public List<CorrelationHandlerResult> correlateMessages(CommandContext commandContext,
 String messageName,
 CorrelationSet correlationSet)

Description copied from interface: CorrelationHandler

Correlate the given message to all waiting executions and all process definitions which have a message start event.

Specified by:

correlateMessages in interface CorrelationHandler

Parameters:

correlationSet - any of its members may be null

Returns:

all matched correlation targets or an empty List if the message could not be correlated.

correlateMessageToExecutions

protected List<CorrelationHandlerResult> correlateMessageToExecutions(CommandContext commandContext,
 String messageName,
 CorrelationSet correlationSet)

correlateStartMessages

public List<CorrelationHandlerResult> correlateStartMessages(CommandContext commandContext,
 String messageName,
 CorrelationSet correlationSet)

Description copied from interface: CorrelationHandler

Correlate the given message to process definitions with a message start event.

Specified by:

correlateStartMessages in interface CorrelationHandler

Parameters:

correlationSet - any of its members may be null

Returns:

the matched correlation targets or an empty list if the message could not be correlated.

correlateStartMessageByEventSubscription

protected List<CorrelationHandlerResult> correlateStartMessageByEventSubscription(CommandContext commandContext,
 String messageName,
 CorrelationSet correlationSet)

findMessageStartEventSubscriptions

protected List<EventSubscriptionEntity> findMessageStartEventSubscriptions(CommandContext commandContext,
 String messageName,
 CorrelationSet correlationSet)

correlateStartMessageByProcessDefinitionId

protected CorrelationHandlerResult correlateStartMessageByProcessDefinitionId(CommandContext commandContext,
 String messageName,
 String processDefinitionId)

findStartActivityIdByMessage

protected String findStartActivityIdByMessage(ProcessDefinitionEntity processDefinition,
 String messageName)

isMessageStartEventWithName

protected boolean isMessageStartEventWithName(EventSubscriptionDeclaration declaration,
 String messageName)