From 64d083866a3e3b552522f3eab1ea0dfa3a5bbb5f Mon Sep 17 00:00:00 2001 From: Shinnosuke Okada Date: Fri, 23 Oct 2020 14:55:24 -0400 Subject: [PATCH] Pass taskListActivitiesPerSecond down to ActivityWorker --- src/main/java/com/uber/cadence/worker/Worker.java | 5 +++-- src/main/java/com/uber/cadence/worker/WorkerOptions.java | 4 ++++ 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/uber/cadence/worker/Worker.java b/src/main/java/com/uber/cadence/worker/Worker.java index 2bbe25358..7f2d0e706 100644 --- a/src/main/java/com/uber/cadence/worker/Worker.java +++ b/src/main/java/com/uber/cadence/worker/Worker.java @@ -84,10 +84,11 @@ public final class Worker implements Suspendable { SingleWorkerOptions activityOptions = SingleWorkerOptions.newBuilder() - .setDataConverter(client.getOptions().getDataConverter()) .setIdentity(client.getOptions().getIdentity()) - .setPollerOptions(options.getActivityPollerOptions()) + .setDataConverter(client.getOptions().getDataConverter()) .setTaskExecutorThreadPoolSize(options.getMaxConcurrentActivityExecutionSize()) + .setTaskListActivitiesPerSecond(options.getTaskListActivitiesPerSecond()) + .setPollerOptions(options.getActivityPollerOptions()) .setMetricsScope(metricsScope) .setEnableLoggingInReplay(factoryOptions.isEnableLoggingInReplay()) .setContextPropagators(contextPropagators) diff --git a/src/main/java/com/uber/cadence/worker/WorkerOptions.java b/src/main/java/com/uber/cadence/worker/WorkerOptions.java index cb66b3ade..5b27b5e89 100644 --- a/src/main/java/com/uber/cadence/worker/WorkerOptions.java +++ b/src/main/java/com/uber/cadence/worker/WorkerOptions.java @@ -192,6 +192,10 @@ public int getMaxConcurrentLocalActivityExecutionSize() { return maxConcurrentLocalActivityExecutionSize; } + public double getTaskListActivitiesPerSecond() { + return taskListActivitiesPerSecond; + } + public PollerOptions getActivityPollerOptions() { return activityPollerOptions; }