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 and return the
MessageCorrelationResult that matches it. |
List<MessageCorrelationResult> |
correlateMessages(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet)
Correlate all given messages and return a
List of MessageCorrelationResult s that matches them. |
protected List<MessageCorrelationResult> |
correlateMessageToExecutions(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet) |
protected MessageCorrelationResult |
tryCorrelateMessageToProcessDefinition(CommandContext commandContext,
String messageName,
CorrelationSet correlationSet) |
public MessageCorrelationResult correlateMessage(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
CorrelationHandler
MessageCorrelationResult
that matches it.
Return null if the message could not be correlated.correlateMessage
in interface CorrelationHandler
correlationSet
- any of its members may be null
public List<MessageCorrelationResult> correlateMessages(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
CorrelationHandler
List
of MessageCorrelationResult
s that matches them.
Return any empty List
if no message could not be correlated.correlateMessages
in interface CorrelationHandler
correlationSet
- any of its members may be null
protected List<MessageCorrelationResult> correlateMessageToExecutions(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
protected MessageCorrelationResult tryCorrelateMessageToProcessDefinition(CommandContext commandContext, String messageName, CorrelationSet correlationSet)
Copyright © 2018. All rights reserved.