Class ActivityExecutionContextFactoryImpl

java.lang.Object

io.temporal.internal.activity.ActivityExecutionContextFactoryImpl

All Implemented Interfaces:

ActivityExecutionContextFactory

public class ActivityExecutionContextFactoryImpl
extends Object
implements ActivityExecutionContextFactory

Constructor Summary

Constructors

Constructor	Description
ActivityExecutionContextFactoryImpl(WorkflowClient client, String identity, String namespace, Duration maxHeartbeatThrottleInterval, Duration defaultHeartbeatThrottleInterval, DataConverter dataConverter, ScheduledExecutorService heartbeatExecutor)

Method Summary

Modifier and Type	Method	Description
boolean	cleanupContext(byte[] taskToken, boolean cancel)	Removes a context for a currently running activity identified by task token and optionally requests cancellation.
InternalActivityExecutionContext	createContext(io.temporal.internal.activity.ActivityInfoInternal info, Object activity, com.uber.m3.tally.Scope metricsScope)

Methods inherited from class java.lang.Object

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

Constructor Details

ActivityExecutionContextFactoryImpl

public ActivityExecutionContextFactoryImpl(WorkflowClient client,
 String identity,
 String namespace,
 Duration maxHeartbeatThrottleInterval,
 Duration defaultHeartbeatThrottleInterval,
 DataConverter dataConverter,
 ScheduledExecutorService heartbeatExecutor)

Method Details

createContext

public InternalActivityExecutionContext createContext(io.temporal.internal.activity.ActivityInfoInternal info,
 Object activity,
 com.uber.m3.tally.Scope metricsScope)

Specified by:

createContext in interface ActivityExecutionContextFactory

cleanupContext

public boolean cleanupContext(byte[] taskToken,
 boolean cancel)

Description copied from interface: ActivityExecutionContextFactory

Removes a context for a currently running activity identified by task token and optionally requests cancellation.

Specified by:

cleanupContext in interface ActivityExecutionContextFactory

Returns:

true if the activity was found and cleaned up.