Class WorkflowClientCallsInterceptorBase

java.lang.Object

io.temporal.common.interceptors.WorkflowClientCallsInterceptorBase

All Implemented Interfaces:

WorkflowClientCallsInterceptor

public class WorkflowClientCallsInterceptorBase
extends Object
implements WorkflowClientCallsInterceptor

Convenience base class for WorkflowClientCallsInterceptor implementations.

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
WorkflowClientCallsInterceptorBase(WorkflowClientCallsInterceptor next)

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

WorkflowClientCallsInterceptorBase

public WorkflowClientCallsInterceptorBase(WorkflowClientCallsInterceptor next)

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

listWorkflowExecutions

public WorkflowClientCallsInterceptor.ListWorkflowExecutionsOutput listWorkflowExecutions(WorkflowClientCallsInterceptor.ListWorkflowExecutionsInput input)

Specified by:

listWorkflowExecutions in interface WorkflowClientCallsInterceptor

countWorkflows

public WorkflowClientCallsInterceptor.CountWorkflowOutput countWorkflows(WorkflowClientCallsInterceptor.CountWorkflowsInput input)

Specified by:

countWorkflows in interface WorkflowClientCallsInterceptor