Class NexusTaskHandlerImpl

java.lang.Object

io.temporal.internal.nexus.NexusTaskHandlerImpl

All Implemented Interfaces:

NexusTaskHandler

public class NexusTaskHandlerImpl
extends Object
implements NexusTaskHandler

Nested Class Summary

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

NexusTaskHandler.Result

Constructor Summary

Constructors

Constructor	Description
NexusTaskHandlerImpl(WorkflowClient client, String namespace, String taskQueue, DataConverter dataConverter, WorkerInterceptor[] interceptors)

Method Summary

Modifier and Type	Method	Description
NexusTaskHandler.Result	handle(NexusTask task, com.uber.m3.tally.Scope metricsScope)
boolean	isAnyTypeSupported()
void	registerNexusServiceImplementations(Object[] nexusServiceImplementation)
CompletionStage<Void>	shutdown(ShutdownManager shutdownManager, boolean unused)
boolean	start()	Start the handler if the handler has any registered services.

Methods inherited from class java.lang.Object

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

Constructor Details

NexusTaskHandlerImpl

public NexusTaskHandlerImpl(@Nonnull
 WorkflowClient client,
 @Nonnull
 String namespace,
 @Nonnull
 String taskQueue,
 @Nonnull
 DataConverter dataConverter,
 @Nonnull
 WorkerInterceptor[] interceptors)

Method Details

isAnyTypeSupported

public boolean isAnyTypeSupported()

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

registerNexusServiceImplementations

public void registerNexusServiceImplementations(Object[] nexusServiceImplementation)

shutdown

public CompletionStage<Void> shutdown(ShutdownManager shutdownManager,
 boolean unused)