Class POJOWorkflowImplementationFactory

java.lang.Object

io.temporal.internal.sync.POJOWorkflowImplementationFactory

All Implemented Interfaces:

ReplayWorkflowFactory

public final class POJOWorkflowImplementationFactory
extends Object
implements ReplayWorkflowFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final com.google.common.collect.ImmutableSet<String>	WORKFLOW_HANDLER_STACKTRACE_CUTOFF

Constructor Summary

Constructors

Constructor	Description
POJOWorkflowImplementationFactory(SingleWorkerOptions singleWorkerOptions, WorkflowThreadExecutor workflowThreadExecutor, WorkerInterceptor[] workerInterceptors, WorkflowExecutorCache cache, String namespace)

Method Summary

Modifier and Type	Method	Description
<R> void	addWorkflowImplementationFactory(WorkflowImplementationOptions options, Class<R> clazz, Functions.Func1<EncodedValues,R> factory)
ReplayWorkflow	getWorkflow(io.temporal.api.common.v1.WorkflowType workflowType, io.temporal.api.common.v1.WorkflowExecution workflowExecution)
boolean	isAnyTypeSupported()
void	registerWorkflowImplementationTypes(WorkflowImplementationOptions options, Class<?>[] workflowImplementationTypes)
String	toString()
static <T> void	validateVersioningBehavior(Class<T> workflowImplementationClass, POJOWorkflowMethodMetadata workflowMethod, VersioningBehavior defaultVersioningBehavior, boolean workerVersioningEnabled)

Methods inherited from class java.lang.Object

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

Field Details

WORKFLOW_HANDLER_STACKTRACE_CUTOFF

public static final com.google.common.collect.ImmutableSet<String> WORKFLOW_HANDLER_STACKTRACE_CUTOFF

Constructor Details

POJOWorkflowImplementationFactory

public POJOWorkflowImplementationFactory(SingleWorkerOptions singleWorkerOptions,
 WorkflowThreadExecutor workflowThreadExecutor,
 WorkerInterceptor[] workerInterceptors,
 WorkflowExecutorCache cache,
 @Nonnull
 String namespace)

Method Details

registerWorkflowImplementationTypes

public void registerWorkflowImplementationTypes(WorkflowImplementationOptions options,
 Class<?>[] workflowImplementationTypes)

addWorkflowImplementationFactory

public <R> void addWorkflowImplementationFactory(WorkflowImplementationOptions options,
 Class<R> clazz,
 Functions.Func1<EncodedValues,R> factory)

Parameters:

clazz - has to be a workflow interface class. The only exception is if it's a DynamicWorkflow class.

getWorkflow

public ReplayWorkflow getWorkflow(io.temporal.api.common.v1.WorkflowType workflowType,
 io.temporal.api.common.v1.WorkflowExecution workflowExecution)

Specified by:

getWorkflow in interface ReplayWorkflowFactory

isAnyTypeSupported

public boolean isAnyTypeSupported()

Specified by:

isAnyTypeSupported in interface ReplayWorkflowFactory

toString

public String toString()

Overrides:

toString in class Object

validateVersioningBehavior

public static <T> void validateVersioningBehavior(Class<T> workflowImplementationClass,
 POJOWorkflowMethodMetadata workflowMethod,
 VersioningBehavior defaultVersioningBehavior,
 boolean workerVersioningEnabled)