Class ActivityTask

java.lang.Object

io.temporal.internal.worker.ActivityTask

All Implemented Interfaces:

ScalingTask

public final class ActivityTask
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
ActivityTask(io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponseOrBuilder response, SlotPermit permit, Functions.Proc completionCallback)

Method Summary

Modifier and Type	Method	Description
Functions.Proc	getCompletionCallback()	Completion handle function that must be called by the handler whenever activity processing is completed.
SlotPermit	getPermit()
io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponseOrBuilder	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

ActivityTask

public ActivityTask(@Nonnull
 io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponseOrBuilder response,
 @Nonnull
 SlotPermit permit,
 @Nonnull
 Functions.Proc completionCallback)

Method Details

getResponse

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

getCompletionCallback

@Nonnull
public Functions.Proc getCompletionCallback()

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

getPermit

@Nonnull
public SlotPermit getPermit()

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.