Class ActivityTaskHandlerImpl

java.lang.Object

io.temporal.internal.activity.ActivityTaskHandlerImpl

All Implemented Interfaces:

ActivityTaskHandler

public final class ActivityTaskHandlerImpl
extends Object
implements ActivityTaskHandler

Nested Class Summary

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

ActivityTaskHandler.Result

Field Summary

Fields

Modifier and Type	Field	Description
static final com.google.common.collect.ImmutableSet<String>	ACTIVITY_HANDLER_STACKTRACE_CUTOFF

Constructor Summary

Constructors

Constructor	Description
ActivityTaskHandlerImpl(String namespace, String taskQueue, DataConverter dataConverter, ActivityExecutionContextFactory executionContextFactory, WorkerInterceptor[] interceptors, List<ContextPropagator> contextPropagators)

Method Summary

Modifier and Type	Method	Description
ActivityTaskHandler.Result	handle(ActivityTask activityTask, com.uber.m3.tally.Scope metricsScope, boolean localActivity)	The implementation should be called when a polling activity worker receives a new activity task.
boolean	isAnyTypeSupported()	True if this handler handles at least one activity type.
boolean	isTypeSupported(String type)
void	registerActivityImplementations(Object[] activitiesImplementation)
boolean	requestCancel(byte[] taskToken)

Methods inherited from class java.lang.Object

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

Field Details

ACTIVITY_HANDLER_STACKTRACE_CUTOFF

public static final com.google.common.collect.ImmutableSet<String> ACTIVITY_HANDLER_STACKTRACE_CUTOFF

Constructor Details

ActivityTaskHandlerImpl

public ActivityTaskHandlerImpl(@Nonnull
 String namespace,
 @Nonnull
 String taskQueue,
 @Nonnull
 DataConverter dataConverter,
 @Nonnull
 ActivityExecutionContextFactory executionContextFactory,
 @Nonnull
 WorkerInterceptor[] interceptors,
 @Nullable
 List<ContextPropagator> contextPropagators)

Method Details

isAnyTypeSupported

public boolean isAnyTypeSupported()

Description copied from interface: ActivityTaskHandler

True if this handler handles at least one activity type.

Specified by:

isAnyTypeSupported in interface ActivityTaskHandler

isTypeSupported

public boolean isTypeSupported(String type)

Specified by:

isTypeSupported in interface ActivityTaskHandler

Parameters:

type - activity type name

Returns:

true if an activity implementation with activityType name is registered or a dynamic activity implementation is registered.

requestCancel

public boolean requestCancel(byte[] taskToken)

registerActivityImplementations

public void registerActivityImplementations(Object[] activitiesImplementation)

handle

public ActivityTaskHandler.Result handle(ActivityTask activityTask,
 com.uber.m3.tally.Scope metricsScope,
 boolean localActivity)

Description copied from interface: ActivityTaskHandler

The implementation should be called when a polling activity worker receives a new activity task. This method shouldn't throw any Throwables unless there is a need to not reply to the task.

Specified by:

handle in interface ActivityTaskHandler

Parameters:

activityTask - activity task which is response to PollActivityTaskQueue call.

Returns:

One of the possible activity task replies.