Class WorkflowTask

java.lang.Object

io.temporal.internal.worker.WorkflowTask

All Implemented Interfaces:

ScalingTask

public class WorkflowTask
extends Object
implements ScalingTask

Nested Class Summary

Nested classes/interfaces inherited from interface io.temporal.internal.worker.ScalingTask

ScalingTask.ScalingDecision

Constructor Summary

Constructors

Constructor	Description
WorkflowTask(io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse response, Functions.Proc1<SlotReleaseReason> completionCallback)

Method Summary

Modifier and Type	Method	Description
Functions.Proc1<SlotReleaseReason>	getCompletionCallback()	Completion handle function that must be called by the handler whenever workflow processing is completed.
io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse	getResponse()
ScalingTask.ScalingDecision	getScalingDecision()	Returns a scaling decision from the task.

Methods inherited from class java.lang.Object

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

Constructor Details

WorkflowTask

public WorkflowTask(@Nonnull
 io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse response,
 @Nonnull
 Functions.Proc1<SlotReleaseReason> completionCallback)

Method Details

getResponse

@Nonnull
public io.temporal.api.workflowservice.v1.PollWorkflowTaskQueueResponse getResponse()

getCompletionCallback

@Nonnull
public Functions.Proc1<SlotReleaseReason> getCompletionCallback()

Completion handle function that must be called by the handler whenever workflow processing is completed.

getScalingDecision

@Nullable
public ScalingTask.ScalingDecision getScalingDecision()

Description copied from interface: ScalingTask

Returns a scaling decision from the task. The decision may be null if no scaling action is needed or not supported.

Specified by:

getScalingDecision in interface ScalingTask

Returns:

a ScalingDecision object containing the scaling suggestion, or null if no action is needed not supported.