Package io.axoniq.framework.workflow.runtime.execution

Class PayloadPropertyWorkflowIdProvider

java.lang.Object

io.axoniq.framework.workflow.runtime.execution.PayloadPropertyWorkflowIdProvider

All Implemented Interfaces:

WorkflowIdProvider, Function<EventMessage,String>

public class PayloadPropertyWorkflowIdProvider
extends Object
implements WorkflowIdProvider

Workflow id provider accessing event message property.

Since:

5.4.0

Author:

Simon Zambrovski

Constructor Summary

Constructors

Constructor	Description
PayloadPropertyWorkflowIdProvider(String attributeName)	Constructs id provider.
PayloadPropertyWorkflowIdProvider(String attributeName, UnaryOperator<String> idProcessor)	Constructs id provider.

Method Summary

Modifier and Type	Method	Description
String	apply(EventMessage eventMessage)
static PayloadPropertyWorkflowIdProvider	fromPayloadAttribute(Configuration configuration, String attributeName, UnaryOperator<String> customizer)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Details

PayloadPropertyWorkflowIdProvider

public PayloadPropertyWorkflowIdProvider(String attributeName)

Constructs id provider.

Parameters:

attributeName - name of the payload attribute.

PayloadPropertyWorkflowIdProvider

public PayloadPropertyWorkflowIdProvider(String attributeName,
 UnaryOperator<String> idProcessor)

Constructs id provider.

Parameters:

attributeName - name of the payload attribute.

idProcessor - processor called on the result of attribute extractor.

Method Details

fromPayloadAttribute

public static PayloadPropertyWorkflowIdProvider fromPayloadAttribute(Configuration configuration,
 String attributeName,
 UnaryOperator<String> customizer)

apply

public String apply(EventMessage eventMessage)

Specified by:

apply in interface Function<EventMessage,String>