File tree Expand file tree Collapse file tree 2 files changed +7
-2
lines changed
src/main/java/com/uber/cadence/worker Expand file tree Collapse file tree 2 files changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -84,10 +84,11 @@ public final class Worker implements Suspendable {
8484
8585 SingleWorkerOptions activityOptions =
8686 SingleWorkerOptions .newBuilder ()
87- .setDataConverter (client .getOptions ().getDataConverter ())
8887 .setIdentity (client .getOptions ().getIdentity ())
89- .setPollerOptions ( options . getActivityPollerOptions ())
88+ .setDataConverter ( client . getOptions (). getDataConverter ())
9089 .setTaskExecutorThreadPoolSize (options .getMaxConcurrentActivityExecutionSize ())
90+ .setTaskListActivitiesPerSecond (options .getTaskListActivitiesPerSecond ())
91+ .setPollerOptions (options .getActivityPollerOptions ())
9192 .setMetricsScope (metricsScope )
9293 .setEnableLoggingInReplay (factoryOptions .isEnableLoggingInReplay ())
9394 .setContextPropagators (contextPropagators )
Original file line number Diff line number Diff line change @@ -192,6 +192,10 @@ public int getMaxConcurrentLocalActivityExecutionSize() {
192192 return maxConcurrentLocalActivityExecutionSize ;
193193 }
194194
195+ public double getTaskListActivitiesPerSecond () {
196+ return taskListActivitiesPerSecond ;
197+ }
198+
195199 public PollerOptions getActivityPollerOptions () {
196200 return activityPollerOptions ;
197201 }
You can’t perform that action at this time.
0 commit comments