public class DefaultCorrelationHandler extends Object implements CorrelationHandler
Constructor and Description |
---|
DefaultCorrelationHandler() |
Modifier and Type | Method and Description |
---|---|
MessageCorrelationResult |
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<MessageCorrelationResult> |
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<MessageCorrelationResult> |
correlateMessageToExecutions(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet) |
protected List<MessageCorrelationResult> |
correlateStartMessageByEventSubscription(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet) |
protected MessageCorrelationResult |
correlateStartMessageByProcessDefinitionId(CommandContext commandContext,
String messageName,
String processDefinitionId) |
List<MessageCorrelationResult> |
correlateStartMessages(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet)
Correlate the given message to process definitions with a message start
event.
|
protected List<MessageEventSubscriptionEntity> |
findMessageStartEventSubscriptions(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet) |
protected String |
findStartActivityIdByMessage(ProcessDefinitionEntity processDefinition,
String messageName) |
protected boolean |
isMessageStartEventWithName(EventSubscriptionDeclaration declaration,
String messageName) |
public MessageCorrelationResult correlateMessage(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
CorrelationHandler
correlateMessage
in interface CorrelationHandler
correlationSet
- any of its members may be null
null
if the message
could not be correlated.public List<MessageCorrelationResult> correlateMessages(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
CorrelationHandler
correlateMessages
in interface CorrelationHandler
correlationSet
- any of its members may be null
protected List<MessageCorrelationResult> correlateMessageToExecutions(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
public List<MessageCorrelationResult> correlateStartMessages(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
CorrelationHandler
correlateStartMessages
in interface CorrelationHandler
correlationSet
- any of its members may be null
protected List<MessageCorrelationResult> correlateStartMessageByEventSubscription(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
protected List<MessageEventSubscriptionEntity> findMessageStartEventSubscriptions(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
protected MessageCorrelationResult correlateStartMessageByProcessDefinitionId(CommandContext commandContext, String messageName, String processDefinitionId)
protected String findStartActivityIdByMessage(ProcessDefinitionEntity processDefinition, String messageName)
protected boolean isMessageStartEventWithName(EventSubscriptionDeclaration declaration, String messageName)
Copyright © 2017. All rights reserved.