public class CorrelationManager extends Object implements Serializable
Constructor and Description |
---|
CorrelationManager() |
Modifier and Type | Method and Description |
---|---|
void |
addMessagePropertyExpression(String correlationRef,
String messageRef,
String propertyName,
CorrelationExpressionEvaluator expression) |
void |
addProcessSubscriptionPropertyExpression(String correlationRef,
String propertyName,
CorrelationExpressionEvaluator expression) |
CorrelationInstance |
computeCorrelationInstance(String messageRef,
Object event) |
CorrelationInstance |
computeSubscription(String messageRef,
Function<String,Object> resolver) |
boolean |
isSubscribe(String messageRef) |
void |
newCorrelation(String correlationRef,
String correlationName) |
void |
newMessage(String id,
String name,
String type) |
void |
setClassLoader(ClassLoader classLoader) |
void |
subscribeTo(String correlationRef) |
public void setClassLoader(ClassLoader classLoader)
public boolean isSubscribe(String messageRef)
public void subscribeTo(String correlationRef)
public CorrelationInstance computeCorrelationInstance(String messageRef, Object event)
public CorrelationInstance computeSubscription(String messageRef, Function<String,Object> resolver)
public void addMessagePropertyExpression(String correlationRef, String messageRef, String propertyName, CorrelationExpressionEvaluator expression)
public void addProcessSubscriptionPropertyExpression(String correlationRef, String propertyName, CorrelationExpressionEvaluator expression)
Copyright © 2001–2021 JBoss by Red Hat. All rights reserved.