1 package com.atlassian.messagequeue.internal.sqs;
2
3 import static java.util.Objects.requireNonNull;
4
5
6
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 }