com.atlassian.messagequeue.internal.sqs

Class DefaultSQSConsumerQueueConfig

java.lang.Object

com.atlassian.messagequeue.internal.sqs.DefaultSQSConsumerQueueConfig

All Implemented Interfaces:

SQSConsumerQueueConfig, SQSQueueConfig

public class DefaultSQSConsumerQueueConfig
extends Object
implements SQSConsumerQueueConfig

Configuration for SQS Consumer Queues

Constructor Summary

Constructors

Constructor and Description
DefaultSQSConsumerQueueConfig(int corePoolSize, int maxPoolSize, int visibilityExtensionPeriod, String queueName, String queueUrl)

Method Summary

Modifier and Type	Method and Description
int	getCorePoolSize()
int	getMaxPoolSize()
String	getQueueName()
String	getQueueUrl()
int	getVisibilityExtensionPeriod()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSQSConsumerQueueConfig

public DefaultSQSConsumerQueueConfig(int corePoolSize,
                                     int maxPoolSize,
                                     int visibilityExtensionPeriod,
                                     String queueName,
                                     String queueUrl)

Method Detail

getCorePoolSize

public int getCorePoolSize()

Specified by:

getCorePoolSize in interface SQSConsumerQueueConfig

getMaxPoolSize

public int getMaxPoolSize()

Specified by:

getMaxPoolSize in interface SQSConsumerQueueConfig

getVisibilityExtensionPeriod

public int getVisibilityExtensionPeriod()

Specified by:

getVisibilityExtensionPeriod in interface SQSConsumerQueueConfig

getQueueName

public String getQueueName()

Specified by:

getQueueName in interface SQSQueueConfig

Returns:

Name of the queue

getQueueUrl

public String getQueueUrl()

Specified by:

getQueueUrl in interface SQSQueueConfig

Returns:

Url of the Queue