com.atlassian.messagequeue.internal.sqs

Class SQSMessageRunnerServiceTest

java.lang.Object

com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

public class SQSMessageRunnerServiceTest
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
SQSMessageRunnerServiceTest()

Method Summary

Modifier and Type	Method and Description
void	addMessageFailsWithEmptyTenantId()
void	addMessageFailsWithExceptionIfTenantContextNotPresent()
void	addMessageFailsWithNullTenantId()
void	addMessageWithEmptyPayload()
void	addMessageWithNullPayload()
void	addMessageWithPayloadContainingIllegalCharacters()
void	addMultipleMessagesConcurrently()
void	addMultipleMessagesSerially()
void	approximateReceiveCountAttributeIsRequested()
void	autoExtensionOfVisibilityTimeout()
void	autoExtensionOfVisibilityTimeoutCancelledOnEarlyAcknowledgement()
void	autoExtensionOfVisibilityTimeoutCancelledOnMessageProcessingException()
void	autoExtensionOfVisibilityTimeoutFailsBecauseMessageNoLongerInFlight() When the visibility timeout of a message expires before we've managed to extend it, then the ChangeMessageVisibility request will throw a MessageNotInflightException .*
void	cancelAutoAcknowledgement()
void	consumerPoolCanRecoverFromError()
void	consumerPoolCanRecoverFromOverLimitException()
void	consumerResumesPollingIfNoMessagesReturnedInOneInvocationOfReceiveMessage()
void	deleteMessageWithoutMessageRunnerKey()
void	deleteMessageWithoutTenantId()
void	doNotProcessInvalidMessageWithValidator()
void	dontProcessAndDeleteMessagesThatCantBeDeserialized()
void	dontProcessMessageWithoutMessageRunner()
void	doProcessValidMessageWithValidator()
void	ensureMessageRunnerKeyIsSentByProducer()
void	ensurePayloadIsSentByProducer()
void	ensureTenantContextEstablishedOnConsumer()
void	ensureTenantDataIdIsSentByProducer()
void	ensureTenantIdIsSentByProducer()
void	ensureWorkContextAvailableForMessageProcessing()
void	failFastIfMessageCantBeSerialized()
void	failFastWhenAddingMessageWithNoRegisteredMessageRunner()
void	messageIsAutoAcknowledgedAfterSuccessfulProcessing()
void	messageNotDeletedIfRunningItThrowsAnException()
void	messageNotProcessedOrDeletedIfTenantContextEstablishmentThrowsException()
void	messagePayloadIsPassedToMessageRunner()
void	messageRunnerResponsiveToCancellationViaShutdown()
void	receiveMessageRequestPerformedUsingConfiguredVisibilityTimeoutAndSchedulingBuffer()
void	sentTimestampAttributeIsRequestedToAllowMessageLatencyToBeDerived()
void	supportEarlyAcknowledgementOfMessage()

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

getDefaultConsumerQueueConfig, getDefaultConsumerQueueConfig, getDefaultMessageRunnerKeyToProducerMapper, setUp, tearDown

Methods inherited from class java.lang.Object

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

Constructor Detail

SQSMessageRunnerServiceTest

public SQSMessageRunnerServiceTest()

Method Detail

messagePayloadIsPassedToMessageRunner

public void messagePayloadIsPassedToMessageRunner()
                                           throws Exception

Throws:

Exception

messageIsAutoAcknowledgedAfterSuccessfulProcessing

public void messageIsAutoAcknowledgedAfterSuccessfulProcessing()
                                                        throws Exception

Throws:

Exception

addMessageWithEmptyPayload

public void addMessageWithEmptyPayload()
                                throws Exception

Throws:

Exception

addMessageWithNullPayload

public void addMessageWithNullPayload()
                               throws Exception

Throws:

Exception

addMultipleMessagesSerially

public void addMultipleMessagesSerially()
                                 throws Exception

Throws:

Exception

addMultipleMessagesConcurrently

public void addMultipleMessagesConcurrently()
                                     throws Exception

Throws:

Exception

messageNotDeletedIfRunningItThrowsAnException

public void messageNotDeletedIfRunningItThrowsAnException()
                                                   throws Exception

Throws:

Exception

receiveMessageRequestPerformedUsingConfiguredVisibilityTimeoutAndSchedulingBuffer

public void receiveMessageRequestPerformedUsingConfiguredVisibilityTimeoutAndSchedulingBuffer()
                                                                                       throws Exception

Throws:

Exception

sentTimestampAttributeIsRequestedToAllowMessageLatencyToBeDerived

public void sentTimestampAttributeIsRequestedToAllowMessageLatencyToBeDerived()
                                                                       throws Exception

Throws:

Exception

approximateReceiveCountAttributeIsRequested

public void approximateReceiveCountAttributeIsRequested()
                                                 throws Exception

Throws:

Exception

consumerResumesPollingIfNoMessagesReturnedInOneInvocationOfReceiveMessage

public void consumerResumesPollingIfNoMessagesReturnedInOneInvocationOfReceiveMessage()
                                                                               throws Exception

Throws:

Exception

addMessageWithPayloadContainingIllegalCharacters

public void addMessageWithPayloadContainingIllegalCharacters()
                                                      throws Exception

Throws:

Exception

addMessageFailsWithExceptionIfTenantContextNotPresent

public void addMessageFailsWithExceptionIfTenantContextNotPresent()
                                                           throws Exception

Throws:

Exception

addMessageFailsWithNullTenantId

public void addMessageFailsWithNullTenantId()
                                     throws Exception

Throws:

Exception

addMessageFailsWithEmptyTenantId

public void addMessageFailsWithEmptyTenantId()
                                      throws Exception

Throws:

Exception

consumerPoolCanRecoverFromOverLimitException

public void consumerPoolCanRecoverFromOverLimitException()
                                                  throws Exception

Throws:

Exception

consumerPoolCanRecoverFromError

public void consumerPoolCanRecoverFromError()
                                     throws Exception

Throws:

Exception

ensureWorkContextAvailableForMessageProcessing

public void ensureWorkContextAvailableForMessageProcessing()
                                                    throws Exception

Throws:

Exception

ensureTenantIdIsSentByProducer

public void ensureTenantIdIsSentByProducer()
                                    throws Exception

Throws:

Exception

ensureMessageRunnerKeyIsSentByProducer

public void ensureMessageRunnerKeyIsSentByProducer()
                                            throws Exception

Throws:

Exception

ensureTenantDataIdIsSentByProducer

public void ensureTenantDataIdIsSentByProducer()
                                        throws Exception

Throws:

Exception

ensurePayloadIsSentByProducer

public void ensurePayloadIsSentByProducer()
                                   throws Exception

Throws:

Exception

dontProcessAndDeleteMessagesThatCantBeDeserialized

public void dontProcessAndDeleteMessagesThatCantBeDeserialized()
                                                        throws Exception

Throws:

Exception

deleteMessageWithoutTenantId

public void deleteMessageWithoutTenantId()
                                  throws Exception

Throws:

Exception

doNotProcessInvalidMessageWithValidator

public void doNotProcessInvalidMessageWithValidator()
                                             throws Exception

Throws:

Exception

doProcessValidMessageWithValidator

public void doProcessValidMessageWithValidator()
                                        throws Exception

Throws:

Exception

deleteMessageWithoutMessageRunnerKey

public void deleteMessageWithoutMessageRunnerKey()
                                          throws Exception

Throws:

Exception

dontProcessMessageWithoutMessageRunner

public void dontProcessMessageWithoutMessageRunner()
                                            throws Exception

Throws:

Exception

failFastIfMessageCantBeSerialized

public void failFastIfMessageCantBeSerialized()
                                       throws Exception

Throws:

Exception

ensureTenantContextEstablishedOnConsumer

public void ensureTenantContextEstablishedOnConsumer()
                                              throws Exception

Throws:

Exception

messageNotProcessedOrDeletedIfTenantContextEstablishmentThrowsException

public void messageNotProcessedOrDeletedIfTenantContextEstablishmentThrowsException()
                                                                             throws Exception

Throws:

Exception

supportEarlyAcknowledgementOfMessage

public void supportEarlyAcknowledgementOfMessage()
                                          throws Exception

Throws:

Exception

failFastWhenAddingMessageWithNoRegisteredMessageRunner

public void failFastWhenAddingMessageWithNoRegisteredMessageRunner()
                                                            throws Exception

Throws:

Exception

messageRunnerResponsiveToCancellationViaShutdown

public void messageRunnerResponsiveToCancellationViaShutdown()
                                                      throws Exception

Throws:

Exception

cancelAutoAcknowledgement

public void cancelAutoAcknowledgement()
                               throws Exception

Throws:

Exception

autoExtensionOfVisibilityTimeout

public void autoExtensionOfVisibilityTimeout()
                                      throws Exception

Throws:

Exception

autoExtensionOfVisibilityTimeoutFailsBecauseMessageNoLongerInFlight

public void autoExtensionOfVisibilityTimeoutFailsBecauseMessageNoLongerInFlight()
                                                                         throws Exception

When the visibility timeout of a message expires before we've managed to extend it, then the ChangeMessageVisibility request will throw a MessageNotInflightException .*

Also, since the visibility timeout has expired, we expect another MessageRunner to start executing the message

We should log this incident appropriately and tune the scheduling buffer time to be big enough to make this very unlikely .

Throws:

Exception

autoExtensionOfVisibilityTimeoutCancelledOnMessageProcessingException

public void autoExtensionOfVisibilityTimeoutCancelledOnMessageProcessingException()
                                                                           throws Exception

Throws:

Exception

autoExtensionOfVisibilityTimeoutCancelledOnEarlyAcknowledgement

public void autoExtensionOfVisibilityTimeoutCancelledOnEarlyAcknowledgement()
                                                                     throws Exception

Throws:

Exception