Class WorkerCommandTaskHandler

java.lang.Object

io.temporal.internal.worker.WorkerCommandTaskHandler

All Implemented Interfaces:

NexusTaskHandler

public final class WorkerCommandTaskHandler
extends Object
implements NexusTaskHandler

Handles server-to-worker commands delivered on the worker command Nexus task queue.

Nested Class Summary

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

NexusTaskHandler.Result

Constructor Summary

Constructors

Constructor	Description
WorkerCommandTaskHandler(Function<byte[],Boolean> activityCancelCallback)

Method Summary

Modifier and Type	Method	Description
NexusTaskHandler.Result	handle(NexusTask task, com.uber.m3.tally.Scope metricsScope)
static SuspendableWorker	newWorkerCommandWorker(io.temporal.serviceclient.WorkflowServiceStubs service, String namespace, String identity, String workerGroupingKey, Function<byte[],Boolean> activityCancelCallback, com.uber.m3.tally.Scope metricsScope, NamespaceCapabilities namespaceCapabilities)
boolean	start()	Start the handler if the handler has any registered services.
static String	workerControlTaskQueue(String namespace, String workerGroupingKey)

Methods inherited from class java.lang.Object

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

Constructor Details

WorkerCommandTaskHandler

public WorkerCommandTaskHandler(Function<byte[],Boolean> activityCancelCallback)

Method Details

workerControlTaskQueue

public static String workerControlTaskQueue(String namespace,
 String workerGroupingKey)

newWorkerCommandWorker

public static SuspendableWorker newWorkerCommandWorker(@Nonnull
 io.temporal.serviceclient.WorkflowServiceStubs service,
 @Nonnull
 String namespace,
 @Nonnull
 String identity,
 @Nonnull
 String workerGroupingKey,
 @Nonnull
 Function<byte[],Boolean> activityCancelCallback,
 @Nonnull
 com.uber.m3.tally.Scope metricsScope,
 @Nonnull
 NamespaceCapabilities namespaceCapabilities)

start

public boolean start()

Description copied from interface: NexusTaskHandler

Start the handler if the handler has any registered services. It is an error to start a handler more than once.

Specified by:

start in interface NexusTaskHandler

Returns:

True if this handler can handle at least one nexus service.

handle

public NexusTaskHandler.Result handle(NexusTask task,
 com.uber.m3.tally.Scope metricsScope)
                               throws TimeoutException

Specified by:

handle in interface NexusTaskHandler

Throws:

TimeoutException