Class DefaultCorrelationHandler
- java.lang.Object
-
- org.camunda.bpm.engine.impl.runtime.DefaultCorrelationHandler
-
- All Implemented Interfaces:
CorrelationHandler
public class DefaultCorrelationHandler extends java.lang.Object implements CorrelationHandler
- Author:
- Thorben Lindhauer, Daniel Meyer, Michael Scholz
-
-
Constructor Summary
Constructors Constructor Description DefaultCorrelationHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CorrelationHandlerResult
correlateMessage(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
Correlate the given message to either a waiting execution or a process definition with a message start event.java.util.List<CorrelationHandlerResult>
correlateMessages(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
Correlate the given message to all waiting executions and all process definitions which have a message start event.protected java.util.List<CorrelationHandlerResult>
correlateMessageToExecutions(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
protected java.util.List<CorrelationHandlerResult>
correlateStartMessageByEventSubscription(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
protected CorrelationHandlerResult
correlateStartMessageByProcessDefinitionId(CommandContext commandContext, java.lang.String messageName, java.lang.String processDefinitionId)
java.util.List<CorrelationHandlerResult>
correlateStartMessages(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
Correlate the given message to process definitions with a message start event.protected java.util.List<EventSubscriptionEntity>
findMessageStartEventSubscriptions(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
protected java.lang.String
findStartActivityIdByMessage(ProcessDefinitionEntity processDefinition, java.lang.String messageName)
protected boolean
isMessageStartEventWithName(EventSubscriptionDeclaration declaration, java.lang.String messageName)
-
-
-
Method Detail
-
correlateMessage
public CorrelationHandlerResult correlateMessage(CommandContext commandContext, java.lang.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 interfaceCorrelationHandler
correlationSet
- any of its members may benull
- Returns:
- the matched correlation target or
null
if the message could not be correlated.
-
correlateMessages
public java.util.List<CorrelationHandlerResult> correlateMessages(CommandContext commandContext, java.lang.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 interfaceCorrelationHandler
correlationSet
- any of its members may benull
- Returns:
- all matched correlation targets or an empty List if the message could not be correlated.
-
correlateMessageToExecutions
protected java.util.List<CorrelationHandlerResult> correlateMessageToExecutions(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
-
correlateStartMessages
public java.util.List<CorrelationHandlerResult> correlateStartMessages(CommandContext commandContext, java.lang.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 interfaceCorrelationHandler
correlationSet
- any of its members may benull
- Returns:
- the matched correlation targets or an empty list if the message could not be correlated.
-
correlateStartMessageByEventSubscription
protected java.util.List<CorrelationHandlerResult> correlateStartMessageByEventSubscription(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
-
findMessageStartEventSubscriptions
protected java.util.List<EventSubscriptionEntity> findMessageStartEventSubscriptions(CommandContext commandContext, java.lang.String messageName, CorrelationSet correlationSet)
-
correlateStartMessageByProcessDefinitionId
protected CorrelationHandlerResult correlateStartMessageByProcessDefinitionId(CommandContext commandContext, java.lang.String messageName, java.lang.String processDefinitionId)
-
findStartActivityIdByMessage
protected java.lang.String findStartActivityIdByMessage(ProcessDefinitionEntity processDefinition, java.lang.String messageName)
-
isMessageStartEventWithName
protected boolean isMessageStartEventWithName(EventSubscriptionDeclaration declaration, java.lang.String messageName)
-
-