View Javadoc

1   package com.atlassian.messagequeue.internal.sqs;
2   
3   import static java.util.Objects.requireNonNull;
4   
5   /**
6    * Configuration for SQS Consumer Queues
7    */
8   public class DefaultSQSConsumerQueueConfig implements SQSConsumerQueueConfig {
9   
10      private final int corePoolSize;
11      private final int maxPoolSize;
12      private final int visibilityExtensionPeriod;
13      private final String queueName;
14      private final String queueUrl;
15  
16      public DefaultSQSConsumerQueueConfig(int corePoolSize, int maxPoolSize, int visibilityExtensionPeriod, String queueName, String queueUrl) {
17          this.corePoolSize = corePoolSize;
18          this.maxPoolSize = maxPoolSize;
19          this.visibilityExtensionPeriod = visibilityExtensionPeriod;
20          this.queueName = requireNonNull(queueName);
21          this.queueUrl = requireNonNull(queueUrl);
22      }
23  
24      @Override
25      public int getCorePoolSize() {
26          return corePoolSize;
27      }
28  
29      @Override
30      public int getMaxPoolSize() {
31          return maxPoolSize;
32      }
33  
34      @Override
35      public int getVisibilityExtensionPeriod() {
36          return visibilityExtensionPeriod;
37      }
38  
39      @Override
40      public String getQueueName() {
41          return queueName;
42      }
43  
44      @Override
45      public String getQueueUrl() {
46          return queueUrl;
47      }
48  }