Package io.dapr.durabletask.runner
Class ActivityRunner
java.lang.Object
io.dapr.durabletask.runner.DurableRunner
io.dapr.durabletask.runner.ActivityRunner
- All Implemented Interfaces:
Runnable
-
Field Summary
Fields inherited from class io.dapr.durabletask.runner.DurableRunner
sidecarClient, tracer, workItem -
Constructor Summary
ConstructorsConstructorDescriptionActivityRunner(OrchestratorService.WorkItem workItem, TaskActivityExecutor taskActivityExecutor, TaskHubSidecarServiceGrpc.TaskHubSidecarServiceBlockingStub sidecarClient, io.opentelemetry.api.trace.Tracer tracer) Constructor. -
Method Summary
Methods inherited from class io.dapr.durabletask.runner.DurableRunner
getSidecarAddress, logException
-
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 executedtaskActivityExecutor- executor for the activitysidecarClient- sidecar client to communicate with the sidecartracer- tracer to be used for tracing
-
-
Method Details
-
run
public void run()
-