Class RootWorkflowClientInvoker

java.lang.Object

io.temporal.internal.client.RootWorkflowClientInvoker

All Implemented Interfaces:

WorkflowClientCallsInterceptor

public class RootWorkflowClientInvoker
extends Object
implements WorkflowClientCallsInterceptor

Nested Class Summary

Nested classes/interfaces inherited from interface io.temporal.common.interceptors.WorkflowClientCallsInterceptor

WorkflowClientCallsInterceptor.CancelInput, WorkflowClientCallsInterceptor.CancelOutput, WorkflowClientCallsInterceptor.CountWorkflowOutput, WorkflowClientCallsInterceptor.CountWorkflowsInput, WorkflowClientCallsInterceptor.DescribeWorkflowInput, WorkflowClientCallsInterceptor.DescribeWorkflowOutput, WorkflowClientCallsInterceptor.GetResultAsyncOutput<R>, WorkflowClientCallsInterceptor.GetResultInput<R>, WorkflowClientCallsInterceptor.GetResultOutput<R>, WorkflowClientCallsInterceptor.ListWorkflowExecutionsInput, WorkflowClientCallsInterceptor.ListWorkflowExecutionsOutput, WorkflowClientCallsInterceptor.PollWorkflowUpdateInput<R>, WorkflowClientCallsInterceptor.PollWorkflowUpdateOutput<R>, WorkflowClientCallsInterceptor.QueryInput<R>, WorkflowClientCallsInterceptor.QueryOutput<R>, WorkflowClientCallsInterceptor.StartUpdateInput<R>, WorkflowClientCallsInterceptor.TerminateInput, WorkflowClientCallsInterceptor.TerminateOutput, WorkflowClientCallsInterceptor.WorkflowSignalInput, WorkflowClientCallsInterceptor.WorkflowSignalOutput, WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput, WorkflowClientCallsInterceptor.WorkflowSignalWithStartOutput, WorkflowClientCallsInterceptor.WorkflowStartInput, WorkflowClientCallsInterceptor.WorkflowStartOutput, WorkflowClientCallsInterceptor.WorkflowUpdateWithStartInput<R>, WorkflowClientCallsInterceptor.WorkflowUpdateWithStartOutput<R>

Constructor Summary

Constructors

Constructor	Description
RootWorkflowClientInvoker(GenericWorkflowClient genericClient, WorkflowClientOptions clientOptions, WorkerFactoryRegistry workerFactoryRegistry)

Method Summary

Modifier and Type	Method	Description
WorkflowClientCallsInterceptor.CancelOutput	cancel(WorkflowClientCallsInterceptor.CancelInput input)
WorkflowClientCallsInterceptor.CountWorkflowOutput	countWorkflows(WorkflowClientCallsInterceptor.CountWorkflowsInput input)
WorkflowClientCallsInterceptor.DescribeWorkflowOutput	describe(WorkflowClientCallsInterceptor.DescribeWorkflowInput input)
<R> WorkflowClientCallsInterceptor.GetResultOutput<R>	getResult(WorkflowClientCallsInterceptor.GetResultInput<R> input)	If you implement this method, WorkflowClientCallsInterceptor.getResultAsync(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.GetResultInput<R>) most likely needs to be implemented too.
<R> WorkflowClientCallsInterceptor.GetResultAsyncOutput<R>	getResultAsync(WorkflowClientCallsInterceptor.GetResultInput<R> input)	If you implement this method, WorkflowClientCallsInterceptor.getResult(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.GetResultInput<R>) most likely needs to be implemented too.
WorkflowClientCallsInterceptor.ListWorkflowExecutionsOutput	listWorkflowExecutions(WorkflowClientCallsInterceptor.ListWorkflowExecutionsInput input)
<R> WorkflowClientCallsInterceptor.PollWorkflowUpdateOutput<R>	pollWorkflowUpdate(WorkflowClientCallsInterceptor.PollWorkflowUpdateInput<R> input)
<R> WorkflowClientCallsInterceptor.QueryOutput<R>	query(WorkflowClientCallsInterceptor.QueryInput<R> input)
WorkflowClientCallsInterceptor.WorkflowSignalOutput	signal(WorkflowClientCallsInterceptor.WorkflowSignalInput input)	If you implement this method, WorkflowClientCallsInterceptor.signalWithStart(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput) most likely needs to be implemented too.
WorkflowClientCallsInterceptor.WorkflowSignalWithStartOutput	signalWithStart(WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput input)
WorkflowClientCallsInterceptor.WorkflowStartOutput	start(WorkflowClientCallsInterceptor.WorkflowStartInput input)	If you implement this method, WorkflowClientCallsInterceptor.signalWithStart(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput) and @{link #updateWithStart} most likely need to be implemented too.
<R> WorkflowUpdateHandle<R>	startUpdate(WorkflowClientCallsInterceptor.StartUpdateInput<R> input)
WorkflowClientCallsInterceptor.TerminateOutput	terminate(WorkflowClientCallsInterceptor.TerminateInput input)
<R> WorkflowClientCallsInterceptor.WorkflowUpdateWithStartOutput<R>	updateWithStart(WorkflowClientCallsInterceptor.WorkflowUpdateWithStartInput<R> input)	Intercepts calls from WorkflowStub.startUpdateWithStart(io.temporal.client.UpdateOptions<R>, java.lang.Object[], java.lang.Object[]) and WorkflowStub.executeUpdateWithStart(io.temporal.client.UpdateOptions<R>, java.lang.Object[], java.lang.Object[]) as well as WorkflowClient.startUpdateWithStart(io.temporal.workflow.Functions.Proc, io.temporal.client.UpdateOptions<R>, io.temporal.client.WithStartWorkflowOperation<?>) and WorkflowClient.executeUpdateWithStart(io.temporal.workflow.Functions.Proc, io.temporal.client.UpdateOptions<R>, io.temporal.client.WithStartWorkflowOperation<?>).

Methods inherited from class java.lang.Object

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

Constructor Details

RootWorkflowClientInvoker

public RootWorkflowClientInvoker(GenericWorkflowClient genericClient,
 WorkflowClientOptions clientOptions,
 WorkerFactoryRegistry workerFactoryRegistry)

Method Details

start

public WorkflowClientCallsInterceptor.WorkflowStartOutput start(WorkflowClientCallsInterceptor.WorkflowStartInput input)

Description copied from interface: WorkflowClientCallsInterceptor

If you implement this method, WorkflowClientCallsInterceptor.signalWithStart(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput) and @{link #updateWithStart} most likely need to be implemented too.

Specified by:

start in interface WorkflowClientCallsInterceptor

See Also:

• WorkflowClientCallsInterceptor.signalWithStart(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput)

signal

public WorkflowClientCallsInterceptor.WorkflowSignalOutput signal(WorkflowClientCallsInterceptor.WorkflowSignalInput input)

Description copied from interface: WorkflowClientCallsInterceptor

If you implement this method, WorkflowClientCallsInterceptor.signalWithStart(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput) most likely needs to be implemented too.

Specified by:

signal in interface WorkflowClientCallsInterceptor

See Also:

• WorkflowClientCallsInterceptor.signalWithStart(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput)

signalWithStart

public WorkflowClientCallsInterceptor.WorkflowSignalWithStartOutput signalWithStart(WorkflowClientCallsInterceptor.WorkflowSignalWithStartInput input)

Specified by:

signalWithStart in interface WorkflowClientCallsInterceptor

updateWithStart

public <R>
WorkflowClientCallsInterceptor.WorkflowUpdateWithStartOutput<R> updateWithStart(WorkflowClientCallsInterceptor.WorkflowUpdateWithStartInput<R> input)

Description copied from interface: WorkflowClientCallsInterceptor

Intercepts calls from WorkflowStub.startUpdateWithStart(io.temporal.client.UpdateOptions<R>, java.lang.Object[], java.lang.Object[]) and WorkflowStub.executeUpdateWithStart(io.temporal.client.UpdateOptions<R>, java.lang.Object[], java.lang.Object[]) as well as WorkflowClient.startUpdateWithStart(io.temporal.workflow.Functions.Proc, io.temporal.client.UpdateOptions<R>, io.temporal.client.WithStartWorkflowOperation<?>) and WorkflowClient.executeUpdateWithStart(io.temporal.workflow.Functions.Proc, io.temporal.client.UpdateOptions<R>, io.temporal.client.WithStartWorkflowOperation<?>).

Specified by:

updateWithStart in interface WorkflowClientCallsInterceptor

getResult

public <R>
WorkflowClientCallsInterceptor.GetResultOutput<R> getResult(WorkflowClientCallsInterceptor.GetResultInput<R> input)
                                                     throws TimeoutException

Description copied from interface: WorkflowClientCallsInterceptor

If you implement this method, WorkflowClientCallsInterceptor.getResultAsync(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.GetResultInput<R>) most likely needs to be implemented too.

Specified by:

getResult in interface WorkflowClientCallsInterceptor

Throws:

TimeoutException

See Also:

• WorkflowClientCallsInterceptor.getResultAsync(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.GetResultInput<R>)

getResultAsync

public <R>
WorkflowClientCallsInterceptor.GetResultAsyncOutput<R> getResultAsync(WorkflowClientCallsInterceptor.GetResultInput<R> input)

Description copied from interface: WorkflowClientCallsInterceptor

If you implement this method, WorkflowClientCallsInterceptor.getResult(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.GetResultInput<R>) most likely needs to be implemented too.

Specified by:

getResultAsync in interface WorkflowClientCallsInterceptor

See Also:

• WorkflowClientCallsInterceptor.getResult(io.temporal.common.interceptors.WorkflowClientCallsInterceptor.GetResultInput<R>)

query

public <R>
WorkflowClientCallsInterceptor.QueryOutput<R> query(WorkflowClientCallsInterceptor.QueryInput<R> input)

Specified by:

query in interface WorkflowClientCallsInterceptor

startUpdate

public <R> WorkflowUpdateHandle<R> startUpdate(WorkflowClientCallsInterceptor.StartUpdateInput<R> input)

Specified by:

startUpdate in interface WorkflowClientCallsInterceptor

pollWorkflowUpdate

public <R>
WorkflowClientCallsInterceptor.PollWorkflowUpdateOutput<R> pollWorkflowUpdate(WorkflowClientCallsInterceptor.PollWorkflowUpdateInput<R> input)

Specified by:

pollWorkflowUpdate in interface WorkflowClientCallsInterceptor

cancel

public WorkflowClientCallsInterceptor.CancelOutput cancel(WorkflowClientCallsInterceptor.CancelInput input)

Specified by:

cancel in interface WorkflowClientCallsInterceptor

terminate

public WorkflowClientCallsInterceptor.TerminateOutput terminate(WorkflowClientCallsInterceptor.TerminateInput input)

Specified by:

terminate in interface WorkflowClientCallsInterceptor

describe

public WorkflowClientCallsInterceptor.DescribeWorkflowOutput describe(WorkflowClientCallsInterceptor.DescribeWorkflowInput input)

Specified by:

describe in interface WorkflowClientCallsInterceptor

countWorkflows

public WorkflowClientCallsInterceptor.CountWorkflowOutput countWorkflows(WorkflowClientCallsInterceptor.CountWorkflowsInput input)

Specified by:

countWorkflows in interface WorkflowClientCallsInterceptor

listWorkflowExecutions

public WorkflowClientCallsInterceptor.ListWorkflowExecutionsOutput listWorkflowExecutions(WorkflowClientCallsInterceptor.ListWorkflowExecutionsInput input)

Specified by:

listWorkflowExecutions in interface WorkflowClientCallsInterceptor