File tree Expand file tree Collapse file tree 3 files changed +0
-11
lines changed
temporal-sdk/src/main/java/io/temporal/worker Expand file tree Collapse file tree 3 files changed +0
-11
lines changed Original file line number Diff line number Diff line change @@ -502,21 +502,18 @@ public Builder setDeploymentOptions(WorkerDeploymentOptions deploymentOptions) {
502502 * <p>If the sticky queue is enabled, the poller behavior will be used for the sticky queue as
503503 * well.
504504 */
505- @ Experimental
506505 public Builder setWorkflowTaskPollersBehavior (PollerBehavior pollerBehavior ) {
507506 this .workflowTaskPollersBehavior = pollerBehavior ;
508507 return this ;
509508 }
510509
511510 /** Set the poller behavior for activity task pollers. */
512- @ Experimental
513511 public Builder setActivityTaskPollersBehavior (PollerBehavior pollerBehavior ) {
514512 this .activityTaskPollersBehavior = pollerBehavior ;
515513 return this ;
516514 }
517515
518516 /** Set the poller behavior for nexus task pollers. */
519- @ Experimental
520517 public Builder setNexusTaskPollersBehavior (PollerBehavior pollerBehavior ) {
521518 this .nexusTaskPollersBehavior = pollerBehavior ;
522519 return this ;
@@ -894,17 +891,14 @@ public WorkerDeploymentOptions getDeploymentOptions() {
894891 return deploymentOptions ;
895892 }
896893
897- @ Experimental
898894 public PollerBehavior getWorkflowTaskPollersBehavior () {
899895 return workflowTaskPollersBehavior ;
900896 }
901897
902- @ Experimental
903898 public PollerBehavior getActivityTaskPollersBehavior () {
904899 return activityTaskPollersBehavior ;
905900 }
906901
907- @ Experimental
908902 public PollerBehavior getNexusTaskPollersBehavior () {
909903 return nexusTaskPollersBehavior ;
910904 }
Original file line number Diff line number Diff line change 11package io .temporal .worker .tuning ;
22
3- import io .temporal .common .Experimental ;
4-
53/**
64 * Defines the behavior of a poller.
75 *
108 * PollerBehaviorSimpleMaximum}. For all intents and purpose this interface should be considered
119 * sealed.
1210 */
13- @ Experimental
1411public interface PollerBehavior {}
Original file line number Diff line number Diff line change 11package io .temporal .worker .tuning ;
22
3- import io .temporal .common .Experimental ;
43import java .util .Objects ;
54import javax .annotation .Nullable ;
65
1110 * <p>If the server does not support autoscaling, then the number of pollers will stay at the
1211 * initial number of pollers.
1312 */
14- @ Experimental
1513public final class PollerBehaviorAutoscaling implements PollerBehavior {
1614 private final int minConcurrentTaskPollers ;
1715 private final int maxConcurrentTaskPollers ;
You can’t perform that action at this time.
0 commit comments