View Javadoc

1   package com.atlassian.messagequeue.internal.sqs.yaml;
2   
3   import static java.util.Objects.requireNonNull;
4   
5   /**
6    * Java object that represents consumer queue config
7    */
8   public class YamlConsumerQueueConfig {
9       private String queueName;
10      private int corePoolSize;
11      private int maxPoolSize;
12      private int visibilityTimeoutExtensionPeriod;
13  
14      public String getQueueName() {
15          return queueName;
16      }
17  
18      public void setQueueName(String queueName) {
19          this.queueName = requireNonNull(queueName);
20      }
21  
22      public int getCorePoolSize() {
23          return corePoolSize;
24      }
25  
26      public void setCorePoolSize(int corePoolSize) {
27          this.corePoolSize = corePoolSize;
28      }
29  
30      public int getMaxPoolSize() {
31          return maxPoolSize;
32      }
33  
34      public void setMaxPoolSize(int maxPoolSize) {
35          this.maxPoolSize = maxPoolSize;
36      }
37  
38      public int getVisibilityTimeoutExtensionPeriod() {
39          return visibilityTimeoutExtensionPeriod;
40      }
41  
42      public void setVisibilityTimeoutExtensionPeriod(int visibilityTimeoutExtensionPeriod) {
43          this.visibilityTimeoutExtensionPeriod = visibilityTimeoutExtensionPeriod;
44      }
45  }