com.atlassian.messagequeue.internal.sqs

Class AbstractSQSMessageRunnerServiceTest

java.lang.Object

com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

Direct Known Subclasses:

MultipleQueuesSQSMessageRunnerServiceTest, SQSMessageRunnerServiceTest

public class AbstractSQSMessageRunnerServiceTest
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractSQSMessageRunnerServiceTest.DefaultMessageRunner
protected static class	AbstractSQSMessageRunnerServiceTest.DelegatingMessageRunner

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	CONCURRENT_CONSUMERS
protected static MessageRunnerKey	MESSAGE_RUNNER_KEY
protected org.mockito.ArgumentCaptor<MessageContext>	messageContextArgumentCaptor
protected MessageInformationService	messageInformationService
protected MessageRunner	messageRunner
protected SQSMessageRunnerKeyToProducerMapper	messageRunnerKeyToProducerMapper
protected SQSMessageRunnerService	messageRunnerService
protected DefaultMessageValidatorRegistryService	messageValidatorRegistry
protected NestedMessageSerializer	nestedMessageSerializer
protected BlockingQueue<String>	payloads
protected static String	QUEUE_NAME
protected String	queueUrl
protected static int	RECEIVE_WAIT_TIME_SECONDS
protected org.mockito.ArgumentCaptor<com.amazonaws.services.sqs.model.ReceiveMessageRequest>	receiveMessageRequestArgumentCaptor
protected DefaultMessageRunnerRegistryService	registryService
protected org.mockito.ArgumentCaptor<com.amazonaws.services.sqs.model.SendMessageRequest>	sendMessageRequestArgumentCaptor
protected com.amazonaws.services.sqs.AmazonSQS	spyingSqsClient
protected com.amazonaws.services.sqs.AmazonSQS	sqsClient
protected com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManager	sqsMessageVisibilityTimeoutManager
protected org.elasticmq.rest.sqs.SQSRestServer	sqsServer
protected static String	TENANT_ID
protected com.atlassian.tenant.api.TenantContext.Builder	tenantContextBuilder
protected com.atlassian.tenant.api.TenantContextProvider	tenantContextProvider
protected TenantDataIdSupplier	tenantDataIdSupplier
protected com.atlassian.tenant.impl.TenantIdSetter	tenantIdSetter
protected static int	VERIFY_TIMEOUT_MILLIS
protected static int	VISIBILITY_TIMEOUT_SECONDS
protected com.atlassian.workcontext.api.WorkContextDoorway	workContextDoorway

Constructor Summary

Constructors

Constructor and Description
AbstractSQSMessageRunnerServiceTest()

Method Summary

Modifier and Type	Method and Description
protected Set<SQSConsumerQueueConfig>	getDefaultConsumerQueueConfig()
protected Set<SQSConsumerQueueConfig>	getDefaultConsumerQueueConfig(int visibilityExtensionSeconds)
protected SQSMessageRunnerKeyToProducerMapper	getDefaultMessageRunnerKeyToProducerMapper()
void	setUp()
void	tearDown()

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_RUNNER_KEY

protected static final MessageRunnerKey MESSAGE_RUNNER_KEY

VISIBILITY_TIMEOUT_SECONDS

protected static final int VISIBILITY_TIMEOUT_SECONDS

See Also:

Constant Field Values

RECEIVE_WAIT_TIME_SECONDS

protected static final int RECEIVE_WAIT_TIME_SECONDS

See Also:

Constant Field Values

QUEUE_NAME

protected static final String QUEUE_NAME

See Also:

Constant Field Values

CONCURRENT_CONSUMERS

protected static final int CONCURRENT_CONSUMERS

See Also:

Constant Field Values

TENANT_ID

protected static final String TENANT_ID

See Also:

Constant Field Values

VERIFY_TIMEOUT_MILLIS

protected static final int VERIFY_TIMEOUT_MILLIS

See Also:

Constant Field Values

messageRunnerService

protected SQSMessageRunnerService messageRunnerService

payloads

protected BlockingQueue<String> payloads

sqsServer

protected org.elasticmq.rest.sqs.SQSRestServer sqsServer

sqsClient

protected com.amazonaws.services.sqs.AmazonSQS sqsClient

spyingSqsClient

protected com.amazonaws.services.sqs.AmazonSQS spyingSqsClient

workContextDoorway

protected com.atlassian.workcontext.api.WorkContextDoorway workContextDoorway

tenantContextProvider

@Mock
protected com.atlassian.tenant.api.TenantContextProvider tenantContextProvider

tenantIdSetter

@Mock
protected com.atlassian.tenant.impl.TenantIdSetter tenantIdSetter

messageRunnerKeyToProducerMapper

@Mock
protected SQSMessageRunnerKeyToProducerMapper messageRunnerKeyToProducerMapper

receiveMessageRequestArgumentCaptor

@Captor
protected org.mockito.ArgumentCaptor<com.amazonaws.services.sqs.model.ReceiveMessageRequest> receiveMessageRequestArgumentCaptor

sendMessageRequestArgumentCaptor

@Captor
protected org.mockito.ArgumentCaptor<com.amazonaws.services.sqs.model.SendMessageRequest> sendMessageRequestArgumentCaptor

messageContextArgumentCaptor

@Captor
protected org.mockito.ArgumentCaptor<MessageContext> messageContextArgumentCaptor

messageRunner

protected MessageRunner messageRunner

registryService

protected DefaultMessageRunnerRegistryService registryService

messageInformationService

protected MessageInformationService messageInformationService

queueUrl

protected String queueUrl

nestedMessageSerializer

protected NestedMessageSerializer nestedMessageSerializer

tenantContextBuilder

protected com.atlassian.tenant.api.TenantContext.Builder tenantContextBuilder

sqsMessageVisibilityTimeoutManager

protected com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManager sqsMessageVisibilityTimeoutManager

tenantDataIdSupplier

protected final TenantDataIdSupplier tenantDataIdSupplier

messageValidatorRegistry

protected DefaultMessageValidatorRegistryService messageValidatorRegistry

Constructor Detail

AbstractSQSMessageRunnerServiceTest

public AbstractSQSMessageRunnerServiceTest()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

getDefaultMessageRunnerKeyToProducerMapper

protected SQSMessageRunnerKeyToProducerMapper getDefaultMessageRunnerKeyToProducerMapper()

getDefaultConsumerQueueConfig

protected Set<SQSConsumerQueueConfig> getDefaultConsumerQueueConfig()

getDefaultConsumerQueueConfig

protected Set<SQSConsumerQueueConfig> getDefaultConsumerQueueConfig(int visibilityExtensionSeconds)