Class ExecuteLocalActivityParameters

java.lang.Object

io.temporal.internal.statemachines.ExecuteLocalActivityParameters

public class ExecuteLocalActivityParameters
extends Object

Constructor Summary

Constructors

Constructor	Description
ExecuteLocalActivityParameters(io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponse.Builder activityTaskBuilder, Duration scheduleToStartTimeout, long originalScheduledTimestamp, io.temporal.api.failure.v1.Failure previousLocalExecutionFailure, boolean doNotIncludeArgumentsIntoMarker, Duration localRetryThreshold, io.temporal.api.sdk.v1.UserMetadata metadata)

Method Summary

Modifier and Type	Method	Description
io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponse.Builder	cloneActivityTaskBuilder()
String	getActivityId()
io.temporal.api.common.v1.ActivityType	getActivityType()
int	getInitialAttempt()
io.temporal.api.common.v1.Payloads	getInput()
Duration	getLocalRetryThreshold()
io.temporal.api.sdk.v1.UserMetadata	getMetadata()
Functions.Proc	getOnNewAttemptCallback()
long	getOriginalScheduledTimestamp()
io.temporal.api.failure.v1.Failure	getPreviousLocalExecutionFailure()
Duration	getScheduleToCloseTimeout()
Duration	getScheduleToStartTimeout()
boolean	isDoNotIncludeArgumentsIntoMarker()
void	setOnNewAttemptCallback(Functions.Proc onNewAttemptCallback)

Methods inherited from class java.lang.Object

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

Constructor Details

ExecuteLocalActivityParameters

public ExecuteLocalActivityParameters(@Nonnull
 io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponse.Builder activityTaskBuilder,
 @Nullable
 Duration scheduleToStartTimeout,
 long originalScheduledTimestamp,
 @Nullable
 io.temporal.api.failure.v1.Failure previousLocalExecutionFailure,
 boolean doNotIncludeArgumentsIntoMarker,
 @Nonnull
 Duration localRetryThreshold,
 io.temporal.api.sdk.v1.UserMetadata metadata)

Method Details

getActivityId

public String getActivityId()

getActivityType

public io.temporal.api.common.v1.ActivityType getActivityType()

getInput

public io.temporal.api.common.v1.Payloads getInput()

getInitialAttempt

public int getInitialAttempt()

cloneActivityTaskBuilder

@Nonnull
public io.temporal.api.workflowservice.v1.PollActivityTaskQueueResponse.Builder cloneActivityTaskBuilder()

Returns:

cloned version of the original activity task builder supplied to these parameters to be used as an attempt base

getScheduleToCloseTimeout

@Nullable
public Duration getScheduleToCloseTimeout()

getOriginalScheduledTimestamp

public long getOriginalScheduledTimestamp()

getPreviousLocalExecutionFailure

@Nullable
public io.temporal.api.failure.v1.Failure getPreviousLocalExecutionFailure()

isDoNotIncludeArgumentsIntoMarker

public boolean isDoNotIncludeArgumentsIntoMarker()

getLocalRetryThreshold

@Nonnull
public Duration getLocalRetryThreshold()

getScheduleToStartTimeout

@Nullable
public Duration getScheduleToStartTimeout()

getOnNewAttemptCallback

@Nonnull
public Functions.Proc getOnNewAttemptCallback()

setOnNewAttemptCallback

public void setOnNewAttemptCallback(@Nonnull
 Functions.Proc onNewAttemptCallback)

getMetadata

public io.temporal.api.sdk.v1.UserMetadata getMetadata()