Pass taskListActivitiesPerSecond down to ActivityWorker

cadence-workflow · Dec 12, 2020 · 64d0838 · 64d0838
1 parent e33ed95
commit 64d0838
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git 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
@@ -192,6 +192,10 @@ public int getMaxConcurrentLocalActivityExecutionSize() {
     return maxConcurrentLocalActivityExecutionSize;
   }
 
+  public double getTaskListActivitiesPerSecond() {
+    return taskListActivitiesPerSecond;
+  }
+
   public PollerOptions getActivityPollerOptions() {
     return activityPollerOptions;
   }