com.atlassian.messagequeue.internal.sqs

Class MultipleQueuesSQSMessageRunnerServiceTest

java.lang.Object

com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

com.atlassian.messagequeue.internal.sqs.MultipleQueuesSQSMessageRunnerServiceTest

public class MultipleQueuesSQSMessageRunnerServiceTest
extends AbstractSQSMessageRunnerServiceTest

Nested Class Summary

Nested classes/interfaces inherited from class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

AbstractSQSMessageRunnerServiceTest.DefaultMessageRunner, AbstractSQSMessageRunnerServiceTest.DelegatingMessageRunner

Field Summary

Fields inherited from class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

CONCURRENT_CONSUMERS, MESSAGE_RUNNER_KEY, messageContextArgumentCaptor, messageInformationService, messageRunner, messageRunnerKeyToProducerMapper, messageRunnerService, messageValidatorRegistry, nestedMessageSerializer, payloads, QUEUE_NAME, queueUrl, RECEIVE_WAIT_TIME_SECONDS, receiveMessageRequestArgumentCaptor, registryService, sendMessageRequestArgumentCaptor, spyingSqsClient, sqsClient, sqsMessageVisibilityTimeoutManager, sqsServer, TENANT_ID, tenantContextBuilder, tenantContextProvider, tenantDataIdSupplier, tenantIdSetter, VERIFY_TIMEOUT_MILLIS, VISIBILITY_TIMEOUT_SECONDS, workContextDoorway

Constructor Summary

Constructors

Constructor and Description
MultipleQueuesSQSMessageRunnerServiceTest()

Method Summary

Modifier and Type	Method and Description
void	failImmediatelyIfNoConsumerQueueConfig()
void	failImmediatelyIfNoProducerQueueConfig()
void	messagesAreSentToCorrectQueues()
void	onlyMatchedMessageIsConsumed()
void	setUp()

Methods inherited from class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

getDefaultConsumerQueueConfig, getDefaultConsumerQueueConfig, getDefaultMessageRunnerKeyToProducerMapper, tearDown

Methods inherited from class java.lang.Object

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

Constructor Detail

MultipleQueuesSQSMessageRunnerServiceTest

public MultipleQueuesSQSMessageRunnerServiceTest()

Method Detail

setUp

public void setUp()
           throws Exception

Overrides:

setUp in class AbstractSQSMessageRunnerServiceTest

Throws:

Exception

messagesAreSentToCorrectQueues

public void messagesAreSentToCorrectQueues()

failImmediatelyIfNoProducerQueueConfig

public void failImmediatelyIfNoProducerQueueConfig()

failImmediatelyIfNoConsumerQueueConfig

public void failImmediatelyIfNoConsumerQueueConfig()

onlyMatchedMessageIsConsumed

public void onlyMatchedMessageIsConsumed()