File tree Expand file tree Collapse file tree 4 files changed +0
-13
lines changed 
temporal-sdk/src/main/java/io/temporal/worker Expand file tree Collapse file tree 4 files changed +0
-13
lines changed Original file line number Diff line number Diff line change @@ -503,21 +503,18 @@ public Builder setDeploymentOptions(WorkerDeploymentOptions deploymentOptions) {
503503     * <p>If the sticky queue is enabled, the poller behavior will be used for the sticky queue as 
504504     * well. 
505505     */ 
506-     @ Experimental 
507506    public  Builder  setWorkflowTaskPollersBehavior (PollerBehavior  pollerBehavior ) {
508507      this .workflowTaskPollersBehavior  = pollerBehavior ;
509508      return  this ;
510509    }
511510
512511    /** Set the poller behavior for activity task pollers. */ 
513-     @ Experimental 
514512    public  Builder  setActivityTaskPollersBehavior (PollerBehavior  pollerBehavior ) {
515513      this .activityTaskPollersBehavior  = pollerBehavior ;
516514      return  this ;
517515    }
518516
519517    /** Set the poller behavior for nexus task pollers. */ 
520-     @ Experimental 
521518    public  Builder  setNexusTaskPollersBehavior (PollerBehavior  pollerBehavior ) {
522519      this .nexusTaskPollersBehavior  = pollerBehavior ;
523520      return  this ;
@@ -895,17 +892,14 @@ public WorkerDeploymentOptions getDeploymentOptions() {
895892    return  deploymentOptions ;
896893  }
897894
898-   @ Experimental 
899895  public  PollerBehavior  getWorkflowTaskPollersBehavior () {
900896    return  workflowTaskPollersBehavior ;
901897  }
902898
903-   @ Experimental 
904899  public  PollerBehavior  getActivityTaskPollersBehavior () {
905900    return  activityTaskPollersBehavior ;
906901  }
907902
908-   @ Experimental 
909903  public  PollerBehavior  getNexusTaskPollersBehavior () {
910904    return  nexusTaskPollersBehavior ;
911905  }
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 ;
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 ;
54
65/** 
76 * A poller behavior that will attempt to poll as long as a slot is available, up to the provided 
87 * maximum. Cannot be less than two for workflow tasks, or one for other tasks. 
98 */ 
10- @ Experimental 
119public  class  PollerBehaviorSimpleMaximum  implements  PollerBehavior  {
1210  private  final  int  maxConcurrentTaskPollers ;
1311
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments