A C D E F G H I J K L M N O P Q R S T U V W

A

abortJobIfDeliveryCountParameterNotAnInt() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

abortJobIfMissingRequiredParameter() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

AbstractNestedMessageSerializerTest - Class in com.atlassian.messagequeue.internal.core

AbstractNestedMessageSerializerTest() - Constructor for class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

AbstractSQSMessageRunnerServiceTest - Class in com.atlassian.messagequeue.internal.sqs

AbstractSQSMessageRunnerServiceTest() - Constructor for class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

AbstractSQSMessageRunnerServiceTest.DefaultMessageRunner - Class in com.atlassian.messagequeue.internal.sqs

AbstractSQSMessageRunnerServiceTest.DelegatingMessageRunner - Class in com.atlassian.messagequeue.internal.sqs

acknowledgeIsThreadSafe() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageContextTest

acknowledgeShouldCancelExtensionOfVisibilityTimeout() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageContextTest

addMessageFailsWithEmptyTenantId() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

addMessageFailsWithExceptionIfTenantContextNotPresent() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

addMessageFailsWithNullTenantId() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

addMessageWithEmptyPayload() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

addMessageWithNullPayload() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

addMessageWithPayloadContainingIllegalCharacters() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

addMultipleMessagesConcurrently() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

addMultipleMessagesConcurrently() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

addMultipleMessagesSerially() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

addMultipleMessagesSerially() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

approximateReceiveCountAttributeIsRequested() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

autoExtensionOfVisibilityTimeout() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

autoExtensionOfVisibilityTimeoutCancelledOnEarlyAcknowledgement() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

autoExtensionOfVisibilityTimeoutCancelledOnMessageProcessingException() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

autoExtensionOfVisibilityTimeoutFailsBecauseMessageNoLongerInFlight() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

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

C

cancelAutoAcknowledgement() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

cancelAutoAcknowledgement() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

changeMessageProcessingTimeoutWithInvalidTimeoutValue() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageContextTest

com.atlassian.messagequeue - package com.atlassian.messagequeue

com.atlassian.messagequeue.internal.core - package com.atlassian.messagequeue.internal.core

com.atlassian.messagequeue.internal.core.messagevalidators - package com.atlassian.messagequeue.internal.core.messagevalidators

com.atlassian.messagequeue.internal.inmemory - package com.atlassian.messagequeue.internal.inmemory

com.atlassian.messagequeue.internal.lifecycle - package com.atlassian.messagequeue.internal.lifecycle

com.atlassian.messagequeue.internal.scheduler - package com.atlassian.messagequeue.internal.scheduler

com.atlassian.messagequeue.internal.sqs - package com.atlassian.messagequeue.internal.sqs

com.atlassian.messagequeue.internal.sqs.yaml - package com.atlassian.messagequeue.internal.sqs.yaml

CONCURRENT_CONSUMERS - Static variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

consume_resilent_when_statsdclient_NOT_available() - Method in class com.atlassian.messagequeue.internal.core.NestedMessageConsumerTest

consume_send_metrics_when_statsdclient_available() - Method in class com.atlassian.messagequeue.internal.core.NestedMessageConsumerTest

consumerPoolCanRecoverFromError() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

consumerPoolCanRecoverFromOverLimitException() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

consumerResumesPollingIfNoMessagesReturnedInOneInvocationOfReceiveMessage() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

D

DefaultInstanceLifecycleNotificationObserverTest - Class in com.atlassian.messagequeue.internal.lifecycle

DefaultInstanceLifecycleNotificationObserverTest() - Constructor for class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

DefaultMessageInformationServiceTest - Class in com.atlassian.messagequeue.internal.core

DefaultMessageInformationServiceTest() - Constructor for class com.atlassian.messagequeue.internal.core.DefaultMessageInformationServiceTest

DefaultMessageRunner(Queue<String>) - Constructor for class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest.DefaultMessageRunner

DefaultMessageRunnerRegistryServiceTest - Class in com.atlassian.messagequeue.internal.core

DefaultMessageRunnerRegistryServiceTest() - Constructor for class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryServiceTest

DelegatingMessageRunner(MessageRunner) - Constructor for class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest.DelegatingMessageRunner

deleteMessageWithoutMessageRunnerKey() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

deleteMessageWithoutTenantId() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

deserialize() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

deserializeAwsCloudFormationNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

deserializeEmptyNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

deserializeEmptyPayload() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

deserializeInstanceActiveLifecycleNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

deserializeInstanceTerminatingLifecycleNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

deserializeMessageFromEmptyPayload() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageInformationServiceTest

deserializeMessageFromNullPayload() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageInformationServiceTest

deserializeNotificationWithInvalidJson() - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

deserializeNullNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

deserializeNullPayload() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

doNotProcessInvalidMessageWithValidator() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

dontProcessAndDeleteMessagesThatCantBeDeserialized() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

dontProcessMessageWithoutMessageRunner() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

doProcessValidMessageWithValidator() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

E

ensureMessageRunnerKeyIsSentByProducer() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

ensurePayloadIsSentByProducer() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

ensureTenantContextEstablishedOnConsumer() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

ensureTenantDataIdIsSentByProducer() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

ensureTenantIdIsSentByProducer() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

ensureWorkContextAvailableForMessageProcessing() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

exceptionInOneListenerDoesNotInterferWithInvocationOfOtherListeners() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

expectedException - Variable in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

F

failFastIfMessageCantBeSerialized() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

failFastIfNoMessageRunnerRegisteredForMessage() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

failFastWhenAddingMessageWithNoRegisteredMessageRunner() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

failImmediatelyIfNoConsumerQueueConfig() - Method in class com.atlassian.messagequeue.internal.sqs.MultipleQueuesSQSMessageRunnerServiceTest

failImmediatelyIfNoProducerQueueConfig() - Method in class com.atlassian.messagequeue.internal.sqs.MultipleQueuesSQSMessageRunnerServiceTest

G

getDefaultConsumerQueueConfig() - Method in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

getDefaultConsumerQueueConfig(int) - Method in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

getDefaultMessageRunnerKeyToProducerMapper() - Method in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

getDefaultQueueConfig() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerKeyToProducerMapperTest

getMessageRunnerWhenNoMessageRunnerExists() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryServiceTest

getQueueConfig() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerKeyToProducerMapperTest

GsonNestedMessageSerializerTest - Class in com.atlassian.messagequeue.internal.core

GsonNestedMessageSerializerTest() - Constructor for class com.atlassian.messagequeue.internal.core.GsonNestedMessageSerializerTest

H

handleInvalidMessage(MessageContext, Map<String, String>) - Method in class com.atlassian.messagequeue.internal.core.messagevalidators.MessageTenantDataIdValidator

I

illegalCharacterThrowsException() - Method in class com.atlassian.messagequeue.MessageTest

isValid(MessageContext, Map<String, String>) - Method in class com.atlassian.messagequeue.internal.core.messagevalidators.MessageTenantDataIdValidator

J

JacksonNestedMessageSerializerTest - Class in com.atlassian.messagequeue.internal.core

JacksonNestedMessageSerializerTest() - Constructor for class com.atlassian.messagequeue.internal.core.JacksonNestedMessageSerializerTest

JacksonNotificationDeserializerTest - Class in com.atlassian.messagequeue.internal.lifecycle

JacksonNotificationDeserializerTest() - Constructor for class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

jobThatRunsLongerThanJobIntervalAllowedToCompleteOnce() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

K

KEY - Static variable in class com.atlassian.messagequeue.internal.core.messagevalidators.MessageTenantDataIdValidator

L

largePayloadSizeThrowsException() - Method in class com.atlassian.messagequeue.MessageTest

listenersAreInvokedOnInstanceTerminatingNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

listenersAreNotInvokedIfInstanceIdsDontMatch() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

listenersAreNotInvokedIfSnsNotificationSubjectIsWrong() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

listenersAreNotInvokedOnInstanceActiveNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

M

MESSAGE_RUNNER_KEY - Static variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

messageAckedEarlyDeliveredExactlyOnce() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageAutoAcknowledgedAndNotRedeliveredAfterSuccessfulProcessing() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageContextArgumentCaptor - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

messageInformationService - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

messageIsAutoAcknowledgedAfterSuccessfulProcessing() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

messageNotDeletedIfRunningItThrowsAnException() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

messageNotDeliveredAfterShutdown() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageNotProcessedIfWorkContextNotAvailable() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageNotProcessedOrDeletedIfTenantContextEstablishmentThrowsException() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

messagePayloadIsPassedToMessageRunner() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

messageProducedAfterSchedulerStopped() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageProducedDuringSchedulerStandbyDeliveredWhenSchedulerStarted() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageRunner - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

messageRunnerKeyToProducerMapper - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

messageRunnerResponsiveToCancellation() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageRunnerResponsiveToCancellationViaShutdown() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

messageRunnerService - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

messagesAreSentToCorrectQueues() - Method in class com.atlassian.messagequeue.internal.sqs.MultipleQueuesSQSMessageRunnerServiceTest

MessageTenantDataIdValidator - Class in com.atlassian.messagequeue.internal.core.messagevalidators

Test validator that uses the data id attribute

MessageTenantDataIdValidator(TenantDataIdSupplier) - Constructor for class com.atlassian.messagequeue.internal.core.messagevalidators.MessageTenantDataIdValidator

MessageTest - Class in com.atlassian.messagequeue

MessageTest() - Constructor for class com.atlassian.messagequeue.MessageTest

messageValidatorRegistry - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

messageWithNullPayloadIsProcessedAtLeastOnce() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

messageWithPayloadIsProcessedAtLeastOnce() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

mockitoRule - Variable in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

mockitoRule - Variable in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

MultipleQueuesSQSMessageRunnerServiceTest - Class in com.atlassian.messagequeue.internal.sqs

MultipleQueuesSQSMessageRunnerServiceTest() - Constructor for class com.atlassian.messagequeue.internal.sqs.MultipleQueuesSQSMessageRunnerServiceTest

N

NestedMessageConsumerTest - Class in com.atlassian.messagequeue.internal.core

NestedMessageConsumerTest() - Constructor for class com.atlassian.messagequeue.internal.core.NestedMessageConsumerTest

nestedMessageSerializer - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

O

onlyMatchedMessageIsConsumed() - Method in class com.atlassian.messagequeue.internal.sqs.MultipleQueuesSQSMessageRunnerServiceTest

P

payloads - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

preserveBackslash() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

preserveBase64Encoding() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

preserveDoubleQuote() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

preserveSQSUnicodeCodePoints() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

#x9 | #xA | #xD | [#x20 to #xD7FF] | [#xE000 to #xFFFD] | [#x10000 to #x10FFFF] (see http://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_SendMessage.html)

problematicJobThatRunsLongerThanJobIntervalAllowedToFailMaxDeliveryCountTimes() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

problematicMessageDeliveredMaxDeliveryCountTimes() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

processMessage(MessageContext) - Method in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest.DefaultMessageRunner

processMessage(MessageContext) - Method in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest.DelegatingMessageRunner

Q

QUEUE_NAME - Static variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

queueUrl - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

R

RECEIVE_WAIT_TIME_SECONDS - Static variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

receiveMessageRequestArgumentCaptor - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

receiveMessageRequestPerformedUsingConfiguredVisibilityTimeoutAndSchedulingBuffer() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

registeredMessageRunnerIsReturned() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryServiceTest

registeringKeyAgainOverridesPreviousRegistration() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryServiceTest

registryService - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

removeMessageRunner() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryServiceTest

rule - Variable in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

rule - Variable in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

rule - Variable in class com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManagerTest

S

SchedulerMessageRunnerServiceTest - Class in com.atlassian.messagequeue.internal.scheduler

SchedulerMessageRunnerServiceTest() - Constructor for class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

sendMessageRequestArgumentCaptor - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

sentTimestampAttributeIsRequestedToAllowMessageLatencyToBeDerived() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

serializationRoundTrip() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageInformationServiceTest

serialize() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

serializeEmptyPayload() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

serializeNullPayload() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

setUp() - Method in class com.atlassian.messagequeue.internal.core.AbstractNestedMessageSerializerTest

setUp() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageInformationServiceTest

setUp() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryServiceTest

setup() - Method in class com.atlassian.messagequeue.internal.core.NestedMessageConsumerTest

setUp() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

setUp() - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializerTest

setUp() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

setUp() - Method in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

setUp() - Method in class com.atlassian.messagequeue.internal.sqs.MultipleQueuesSQSMessageRunnerServiceTest

setUp() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageContextTest

setUp() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerKeyToProducerMapperTest

setUp() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManagerTest

spyingSqsClient - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

sqsClient - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

SQSMessageContextTest - Class in com.atlassian.messagequeue.internal.sqs

SQSMessageContextTest() - Constructor for class com.atlassian.messagequeue.internal.sqs.SQSMessageContextTest

SQSMessageRunnerKeyToProducerMapperTest - Class in com.atlassian.messagequeue.internal.sqs

SQSMessageRunnerKeyToProducerMapperTest() - Constructor for class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerKeyToProducerMapperTest

SQSMessageRunnerServiceTest - Class in com.atlassian.messagequeue.internal.sqs

SQSMessageRunnerServiceTest() - Constructor for class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

sqsMessageVisibilityTimeoutManager - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

SQSMessageVisibilityTimeoutManagerTest - Class in com.atlassian.messagequeue.internal.sqs

SQSMessageVisibilityTimeoutManagerTest() - Constructor for class com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManagerTest

sqsServer - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

SQSYamlConfigParserTest - Class in com.atlassian.messagequeue.internal.sqs.yaml

SQSYamlConfigParserTest() - Constructor for class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

stopExtendingVisibilityTimeoutOnException() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManagerTest

supportEarlyAcknowledgementOfMessage() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerServiceTest

T

teardown() - Method in class com.atlassian.messagequeue.internal.core.NestedMessageConsumerTest

tearDown() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserverTest

tearDown() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

tearDown() - Method in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

tearDown() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManagerTest

TENANT_ID - Static variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

tenantContextBuilder - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

tenantContextProvider - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

tenantDataIdSupplier - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

tenantIdSetter - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

TestInMemoryMessageRunnerServiceImpl - Class in com.atlassian.messagequeue.internal.inmemory

TestInMemoryMessageRunnerServiceImpl() - Constructor for class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

testInvalidQueueNameInConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testMoreThanOneDefaultQueueConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testNoCorePoolSizeConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testNoDefaultQueueConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testNoMaxPoolSizeConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testNoQueueInConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testNoTimeoutConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testNoWorkerGroupConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testNullPayload() - Method in class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

testQueueNotBelongToWorkerGroupConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testQueueNotBelongToWorkerGroupConfig2() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testRegisterAndRunMessage() - Method in class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

testRunNonExistentMessageFails() - Method in class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

testSecondRegisterWins() - Method in class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

testUnregister() - Method in class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

testUnregisterFailsCleanly() - Method in class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

testValidConfig() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParserTest

testWorkContextEstablished() - Method in class com.atlassian.messagequeue.internal.inmemory.TestInMemoryMessageRunnerServiceImpl

throwExceptionIfReceiptIsInvalid() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageContextTest

U

unregisterIsNoOpForKeyWithoutAnAssociatedRunner() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryServiceTest

V

VERIFY_TIMEOUT_MILLIS - Static variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

VISIBILITY_TIMEOUT_SECONDS - Static variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

visibilityTimeoutExtensionRecurs() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageVisibilityTimeoutManagerTest

W

workContextDoorway - Variable in class com.atlassian.messagequeue.internal.sqs.AbstractSQSMessageRunnerServiceTest

A C D E F G H I J K L M N O P Q R S T U V W