Package io.dapr.durabletask.runner

Class ActivityRunner

java.lang.Object

io.dapr.durabletask.runner.DurableRunner

io.dapr.durabletask.runner.ActivityRunner

All Implemented Interfaces:

Runnable

public class ActivityRunner
extends DurableRunner

Field Summary

Fields inherited from class io.dapr.durabletask.runner.DurableRunner

sidecarClient, tracer, workItem

Constructor Summary

Constructors

Constructor	Description
ActivityRunner(OrchestratorService.WorkItem workItem, TaskActivityExecutor taskActivityExecutor, TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient, io.opentelemetry.api.trace.Tracer tracer)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class io.dapr.durabletask.runner.DurableRunner

getSidecarAddress, logException

Methods inherited from class java.lang.Object

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

Constructor Details

ActivityRunner

public ActivityRunner(OrchestratorService.WorkItem workItem,
 TaskActivityExecutor taskActivityExecutor,
 TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient,
 @Nullable
 io.opentelemetry.api.trace.Tracer tracer)

Constructor.

This class executes the activity requests

Parameters:

workItem - work item to be executed

taskActivityExecutor - executor for the activity

sidecarClient - sidecar client to communicate with the sidecar

tracer - tracer to be used for tracing

Method Details

run

public void run()