A B C D E F G H I J M N O P R S T U W Y

A

acknowledge() - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageContext

acknowledge() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageContext

acknowledge() - Method in interface com.atlassian.messagequeue.registry.MessageContext

Called by a message consumer to acknowledge the receipt of a message and prevent it's redelivery to another consumer.

addAttribute(String, String) - Method in class com.atlassian.messagequeue.internal.core.NestedMessage

addInstanceTerminatingListener(InstanceLifecycleListener) - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserver

Register a listener to respond to instance terminating notification.

addInstanceTerminatingListener(InstanceLifecycleListener) - Method in interface com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotificationObserver

Register the specified listener to be notified when an instance is terminating.

addInstanceTerminatingListener(InstanceLifecycleListener) - Method in class com.atlassian.messagequeue.internal.lifecycle.NoOpInstanceLifecycleNotificationObserver

addMessage(Message) - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageRunnerService

addMessage(Message) - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerService

addMessage(Message) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService

addMessage(Message) - Method in interface com.atlassian.messagequeue.MessageRunnerService

Adds a message that will be executed at some future point.

B

build() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

build() - Method in class com.atlassian.messagequeue.Message.Builder

builder(MessageRunnerKey) - Static method in class com.atlassian.messagequeue.Message

Builder factory method

C

cancelAutoAcknowledgementOfMessage() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageContext

cancelAutoAcknowledgementOfMessage() - Method in interface com.atlassian.messagequeue.registry.MessageContext

Cancels the auto-acknowledgement of the message in this context.

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

SQS-specific message runner support.

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

SQS YAML config support.

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

Package that handles the registration of MessageRunners under keys.

compareTo(MessageRunnerKey) - Method in class com.atlassian.messagequeue.MessageRunnerKey

compareTo(MessageValidatorKey) - Method in class com.atlassian.messagequeue.MessageValidatorKey

consume(NestedMessage, MessageContext) - Method in class com.atlassian.messagequeue.internal.core.NestedMessageConsumer

Consumes a NestedMessage.

create(MessageRunnerKey, String) - Static method in class com.atlassian.messagequeue.Message

Message factory method

D

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

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

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

Observes EC2 instance lifecycle notifications.

DefaultInstanceLifecycleNotificationObserver(String, AmazonSQSClient, NotificationDeserializer) - Constructor for class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserver

Constructs an instance of InstanceLifecycleNotificationObserver.

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

Message information service.

DefaultMessageInformationService(String, TenantContextProvider, NestedMessageSerializer, TenantDataIdSupplier) - Constructor for class com.atlassian.messagequeue.internal.core.DefaultMessageInformationService

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

A default message runner registry that stores registrations in memory in a concurrent data structure.

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

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

A default message runner registry that stores registrations in memory in a concurrent data structure.

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

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

Configuration for SQS Consumer Queues

DefaultSQSConsumerQueueConfig(int, int, int, String, String) - Constructor for class com.atlassian.messagequeue.internal.sqs.DefaultSQSConsumerQueueConfig

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

Default implementation of SQSMessageRunnerKeyToProducerMapper Return SQSProducerQueueConfig for provided MessageRunnerKey from the map or default one if MessageRunnerKey is not in the map

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

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

Configuration for SQS Producer Queues.

DefaultSQSProducerQueueConfig(String, String) - Constructor for class com.atlassian.messagequeue.internal.sqs.DefaultSQSProducerQueueConfig

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

Thread factory.

DefaultThreadFactory(String, Thread.UncaughtExceptionHandler) - Constructor for class com.atlassian.messagequeue.internal.core.DefaultThreadFactory

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

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

deserialize(String) - Method in interface com.atlassian.messagequeue.internal.core.NestedMessageSerializer

Deserialize the specified string.

deserialize(String, Class<T>) - Method in class com.atlassian.messagequeue.internal.lifecycle.JacksonNotificationDeserializer

deserialize(String, Class<T>) - Method in interface com.atlassian.messagequeue.internal.lifecycle.NotificationDeserializer

E

equals(Object) - Method in class com.atlassian.messagequeue.Message

equals(Object) - Method in class com.atlassian.messagequeue.MessageRunnerKey

equals(Object) - Method in class com.atlassian.messagequeue.MessageValidatorKey

F

fromPayload(String) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageInformationService

fromPayload(String) - Method in interface com.atlassian.messagequeue.MessageInformationService

Deserializes a Message from the specified atlassian-messagequeue formatted payload.

G

getAllValidators() - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageValidatorRegistryService

getAllValidators() - Method in interface com.atlassian.messagequeue.internal.core.MessageValidatorRegistryHelper

Retrieves all message validators.

getAttribute(String) - Method in class com.atlassian.messagequeue.internal.core.NestedMessage

getAutoScalingGroupName() - Method in class com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotification

getConsumerQueues() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlWorkerGroupConfig

getCorePoolSize() - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSConsumerQueueConfig

getCorePoolSize() - Method in interface com.atlassian.messagequeue.internal.sqs.SQSConsumerQueueConfig

getCorePoolSize() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

getDefaultQueue() - Method in class com.atlassian.messagequeue.internal.sqs.SQSConfig

getEc2InstanceId() - Method in class com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotification

getFirstDeliveryTime() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerService

Returns message first delivery time.

getInboundQueueMappings() - Method in class com.atlassian.messagequeue.internal.sqs.SQSConfig

getInstanceLifecycleNotification() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleContext

getInstanceLifecycleNotification() - Method in interface com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleContext

getKey() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlMessageRunnerConfig

getLifecycleActionToken() - Method in class com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotification

getLifecycleHookName() - Method in class com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotification

getLifecycleTransition() - Method in class com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotification

getMaxPoolSize() - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSConsumerQueueConfig

getMaxPoolSize() - Method in interface com.atlassian.messagequeue.internal.sqs.SQSConsumerQueueConfig

getMaxPoolSize() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

getMessage() - Method in class com.atlassian.messagequeue.internal.lifecycle.SNSNotification

getMessageId() - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageContext

getMessageId() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageContext

getMessageId() - Method in interface com.atlassian.messagequeue.registry.MessageContext

getMessageRunner(MessageRunnerKey) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryService

getMessageRunner(MessageRunnerKey) - Method in interface com.atlassian.messagequeue.internal.core.MessageRunnerRegistryHelper

Retrieves the message runner registered against the specified key.

getMessageRunner(MessageRunnerKey) - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageRunnerService

getMessageRunners() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlQueueConfig

getName() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlWorkerGroupConfig

getOutboundQueueNameMappings() - Method in class com.atlassian.messagequeue.internal.sqs.SQSConfig

getPayload() - Method in class com.atlassian.messagequeue.internal.core.NestedMessage

getPayload() - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageContext

getPayload() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageContext

getPayload() - Method in class com.atlassian.messagequeue.Message

getPayload() - Method in interface com.atlassian.messagequeue.registry.MessageContext

getQueueConfigForMessageRunner(MessageRunnerKey) - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSMessageRunnerKeyToProducerMapper

getQueueConfigForMessageRunner(MessageRunnerKey) - Method in interface com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerKeyToProducerMapper

getQueueName() - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSConsumerQueueConfig

getQueueName() - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSProducerQueueConfig

getQueueName() - Method in interface com.atlassian.messagequeue.internal.sqs.SQSQueueConfig

getQueueName() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

getQueueName() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlQueueConfig

getQueues() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConfig

getQueueUrl(MessageRunnerKey) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageInformationService

getQueueUrl() - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSConsumerQueueConfig

getQueueUrl() - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSProducerQueueConfig

getQueueUrl(MessageRunnerKey) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageInformationService

getQueueUrl() - Method in interface com.atlassian.messagequeue.internal.sqs.SQSQueueConfig

getQueueUrl(MessageRunnerKey) - Method in interface com.atlassian.messagequeue.MessageInformationService

Returns the queue URL that atlassian-messagequeue is consuming from and producing to for the specified message runner key.

getRunnerKey() - Method in class com.atlassian.messagequeue.Message

Returns the MessageRunnerKey which specifies a MessageRunner with which this Message should be handled by.

getSubject() - Method in class com.atlassian.messagequeue.internal.lifecycle.SNSNotification

getVisibilityExtensionPeriod() - Method in class com.atlassian.messagequeue.internal.sqs.DefaultSQSConsumerQueueConfig

getVisibilityExtensionPeriod() - Method in interface com.atlassian.messagequeue.internal.sqs.SQSConsumerQueueConfig

getVisibilityTimeoutExtensionPeriod() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

getWorkerGroups() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConfig

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

Implementation using Gson (https://github.com/google/gson).

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

H

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

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

handleInvalidMessage(MessageContext, Map<String, String>) - Method in interface com.atlassian.messagequeue.registry.MessageValidator

handleInvalidMessage is called for any message that fails isValid.

hashCode() - Method in class com.atlassian.messagequeue.Message

hashCode() - Method in class com.atlassian.messagequeue.MessageRunnerKey

hashCode() - Method in class com.atlassian.messagequeue.MessageValidatorKey

I

init() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerService

Initialises this instance.

initialise() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserver

initialise() - Method in interface com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotificationObserver

Initialise this observer.

initialise() - Method in class com.atlassian.messagequeue.internal.lifecycle.NoOpInstanceLifecycleNotificationObserver

initialiseMessageConsumers() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService

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

In-memory message context.

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

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

Implementation of both MessageRunnerService and MessageRunnerRegistryService.

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

InstanceLifecycleContext - Interface in com.atlassian.messagequeue.internal.lifecycle

Instance lifecycle context.

InstanceLifecycleListener - Interface in com.atlassian.messagequeue.internal.lifecycle

A listener for instance lifecycle notifications.

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

A EC2 instance lifecycle notification.

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

InstanceLifecycleNotificationObserver - Interface in com.atlassian.messagequeue.internal.lifecycle

Observes instance lifecycle notifications.

InvalidMessagePayloadException - Exception in com.atlassian.messagequeue

Thrown when invalid characters are detected in the payload of a Message.

InvalidMessagePayloadException(MessageRunnerKey, int) - Constructor for exception com.atlassian.messagequeue.InvalidMessagePayloadException

Constructs a new instance of invalid message payload exception.

isCancellationRequested() - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageContext

isCancellationRequested() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageContext

isCancellationRequested() - Method in interface com.atlassian.messagequeue.registry.MessageContext

Returns true if the MessageRunner should terminate its activities as gracefully as possible and exit; false to continue running normally.

isDefault() - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlQueueConfig

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

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

isValid(MessageContext, Map<String, String>) - Method in interface com.atlassian.messagequeue.registry.MessageValidator

Is the message valid? If not then the message will not be processed by its message runner, and handleInvalidMessage will be called.

J

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

Implementation using Jackson (https://github.com/FasterXML/jackson).

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

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

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

M

MDC_MESSAGE_RUNNER_KEY - Static variable in class com.atlassian.messagequeue.internal.core.NestedMessageConsumer

Message - Class in com.atlassian.messagequeue

Encapsulates information that is passed to MessageRunnerService.addMessage(Message).

Message.Builder - Class in com.atlassian.messagequeue

Message Builder

MESSAGE_RUNNER_KEY_ATTRIBUTE_NAME - Static variable in class com.atlassian.messagequeue.internal.core.NestedMessageConstants

Stores a key that uniquely a MessageRunner

MessageAcknowledgementException - Exception in com.atlassian.messagequeue

Thrown to indicate an error when acknowledging a message.

MessageAcknowledgementException(String, Throwable) - Constructor for exception com.atlassian.messagequeue.MessageAcknowledgementException

Constructs a new instance of message acknowledgement exception.

MessageContext - Interface in com.atlassian.messagequeue.registry

Context that is passed to an execution of a message.

MessageInformationService - Interface in com.atlassian.messagequeue

A service that provides sufficient information to enable clients to perform their own delivery of Messages to a queue.

MessagePayloadSizeExceededException - Exception in com.atlassian.messagequeue

Thrown on message runner invocation when a payload that is too large is passed.

MessagePayloadSizeExceededException(MessageRunnerKey, long) - Constructor for exception com.atlassian.messagequeue.MessagePayloadSizeExceededException

MessageRunner - Interface in com.atlassian.messagequeue.registry

Message Runner SPI.

MessageRunnerConstants - Class in com.atlassian.messagequeue

Constants for the MessageRunner system.

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

MessageRunnerKey - Class in com.atlassian.messagequeue

Message runner key

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

Ensures that every message has a message runner key.

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

MessageRunnerNotRegisteredException - Exception in com.atlassian.messagequeue

Thrown on message runner invocation when a message with the given key cannot be found.

MessageRunnerNotRegisteredException(MessageRunnerKey) - Constructor for exception com.atlassian.messagequeue.MessageRunnerNotRegisteredException

MessageRunnerRegistryHelper - Interface in com.atlassian.messagequeue.internal.core

Allows MessageRunners to be retrieved from the MessageRunnerRegistryService.

MessageRunnerRegistryService - Interface in com.atlassian.messagequeue.registry

Interface for registering and unregistering message runners.

MessageRunnerService - Interface in com.atlassian.messagequeue

Interface for running messages.

MessageRunnerServiceException - Exception in com.atlassian.messagequeue

Thrown to indicate an error in a message runner operation.

MessageRunnerServiceException(String) - Constructor for exception com.atlassian.messagequeue.MessageRunnerServiceException

Constructs a MessageRunnerServiceException.

MessageRunnerServiceException(String, Throwable) - Constructor for exception com.atlassian.messagequeue.MessageRunnerServiceException

Constructs a MessageRunnerServiceException.

MessageRunnerServiceException(Throwable) - Constructor for exception com.atlassian.messagequeue.MessageRunnerServiceException

Constructs a MessageRunnerServiceException.

MessageSerializationException - Exception in com.atlassian.messagequeue

Thrown to indicate an error in serializing or deserializing a message.

MessageSerializationException(String, Throwable) - Constructor for exception com.atlassian.messagequeue.MessageSerializationException

Constructs a new message serialization exception.

MessageValidator - Interface in com.atlassian.messagequeue.registry

Provides a mechanism to validate or filter messages based on their attributes and context.

MessageValidatorKey - Class in com.atlassian.messagequeue

Message validator key

MessageValidatorRegistryHelper - Interface in com.atlassian.messagequeue.internal.core

Allows MessageValidators to be retrieved from the MessageValidatorRegistryService.

MessageValidatorRegistryService - Interface in com.atlassian.messagequeue.registry

Interface for registering and unregistering message validators.

N

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

A message intended to be nested inside the payload of a SQS message.

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

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

Contains NestedMessage constants.

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

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

Consumes a NestedMessage.

NestedMessageConsumer(MessageRunnerRegistryHelper, TenantIdSetter, MessageValidatorRegistryHelper) - Constructor for class com.atlassian.messagequeue.internal.core.NestedMessageConsumer

Constructs an instance of NestedMessageConsumer.

NestedMessageSerializer - Interface in com.atlassian.messagequeue.internal.core

Responsible for handling serialization and deserialization for NestedMessage.

newBuilder(SQSMessageRunnerKeyToProducerMapper, Set<SQSConsumerQueueConfig>) - Static method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService

Create a new SQSMessageRunnerService builder

newThread(Runnable) - Method in class com.atlassian.messagequeue.internal.core.DefaultThreadFactory

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

Noop implementation.

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

NotificationDeserializer - Interface in com.atlassian.messagequeue.internal.lifecycle

Deserializes lifecycle notifications.

O

of(String) - Static method in class com.atlassian.messagequeue.MessageRunnerKey

Wraps the provided string as a MessageRunnerKey.

of(String) - Static method in class com.atlassian.messagequeue.MessageValidatorKey

Wraps the provided string as a MessageValidatorKey.

onInstanceLifecycleNotification(InstanceLifecycleContext) - Method in interface com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleListener

Called on an instance lifecycle notification.

P

parse(Supplier<String>, Predicate<String>, Function<String, String>) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.SQSYamlConfigParser

Parse yaml config

payload(String) - Method in class com.atlassian.messagequeue.Message.Builder

payloadMaxSize() - Static method in class com.atlassian.messagequeue.MessageRunnerConstants

Note that this is deliberately not exposed as a system property.

processMessage(MessageContext) - Method in interface com.atlassian.messagequeue.registry.MessageRunner

Entry point for running this message.

R

registerMessageRunner(MessageRunnerKey, MessageRunner) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryService

registerMessageRunner(MessageRunnerKey, MessageRunner) - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageRunnerService

registerMessageRunner(MessageRunnerKey, MessageRunner) - Method in interface com.atlassian.messagequeue.registry.MessageRunnerRegistryService

Register a message runner on the given key.

registerMessageValidator(MessageValidatorKey, MessageValidator) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageValidatorRegistryService

registerMessageValidator(MessageValidatorKey, MessageValidator) - Method in interface com.atlassian.messagequeue.registry.MessageValidatorRegistryService

Register a message validator on the given key.

S

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

Scheduler MessageContext.

SchedulerMessageContext(JobRunnerRequest, String, SchedulerService) - Constructor for class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageContext

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

An implementation of MessageRunnerService that is backed by the SchedulerService that provides at-least-once delivery semantics.

SchedulerMessageRunnerService(SchedulerService, MessageRunnerRegistryHelper, MessageInformationService, NestedMessageSerializer) - Constructor for class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerService

Constructs a new instance of SchedulerMessageRunnerService.

SchedulerMessageRunnerService(SchedulerService, MessageRunnerRegistryHelper, MessageInformationService, NestedMessageSerializer, long, int) - Constructor for class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerService

Constructs a new instance of SchedulerMessageRunnerService.

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

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

serialize(NestedMessage) - Method in interface com.atlassian.messagequeue.internal.core.NestedMessageSerializer

Serialize message.

setConsumerQueues(List<YamlConsumerQueueConfig>) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlWorkerGroupConfig

setCorePoolSize(int) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

setDefault(boolean) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlQueueConfig

setKey(String) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlMessageRunnerConfig

setMaxPoolSize(int) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

setMessageRunners(List<YamlMessageRunnerConfig>) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlQueueConfig

setName(String) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlWorkerGroupConfig

setPayload(String) - Method in class com.atlassian.messagequeue.internal.core.NestedMessage

setQueueName(String) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

setQueueName(String) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlQueueConfig

setQueues(List<YamlQueueConfig>) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConfig

setVisibilityTimeoutExtensionPeriod(int) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConsumerQueueConfig

setWorkerGroups(List<YamlWorkerGroupConfig>) - Method in class com.atlassian.messagequeue.internal.sqs.yaml.YamlConfig

shouldAutoAcknowledgeMessage() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageContext

shouldAutoAcknowledgeMessage() - Method in interface com.atlassian.messagequeue.registry.MessageContext

shutdown() - Method in class com.atlassian.messagequeue.internal.lifecycle.DefaultInstanceLifecycleNotificationObserver

shutdown() - Method in interface com.atlassian.messagequeue.internal.lifecycle.InstanceLifecycleNotificationObserver

Shutdown this observer.

shutdown() - Method in class com.atlassian.messagequeue.internal.lifecycle.NoOpInstanceLifecycleNotificationObserver

shutdown() - Method in class com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerService

Shuts down this instance.

shutdown() - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService

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

A SNS notification.

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

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

SQS config contains SQSConfig.outboundQueueNameMappings map of MessageRunnerKey to SQSProducerQueueConfig SQSConfig.inboundQueueMappings map of worker group's name to SQSConsumerQueueConfig SQSConfig.defaultQueueConfig default SQSProducerQueueConfig

SQSConfig(SQSProducerQueueConfig, Map<MessageRunnerKey, SQSProducerQueueConfig>, Map<String, Set<SQSConsumerQueueConfig>>) - Constructor for class com.atlassian.messagequeue.internal.sqs.SQSConfig

SQSConsumerQueueConfig - Interface in com.atlassian.messagequeue.internal.sqs

Configuration for SQS Consumer Queues

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

SQS variant of DefaultMessageInformationService.

SQSMessageInformationService(SQSMessageRunnerKeyToProducerMapper, TenantContextProvider, NestedMessageSerializer, TenantDataIdSupplier) - Constructor for class com.atlassian.messagequeue.internal.sqs.SQSMessageInformationService

SQSMessageRunnerKeyToProducerMapper - Interface in com.atlassian.messagequeue.internal.sqs

Maps from a MessageRunnerKey to a SQSProducerQueueConfig

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

SQS message runner service that produces messages onto an SQS queue and manages a pool of threads that consume from said queue.

SQSMessageRunnerService.Builder - Class in com.atlassian.messagequeue.internal.sqs

A builder to help make the SQSMessageRunnerService.

SQSProducerQueueConfig - Interface in com.atlassian.messagequeue.internal.sqs

Configuration for SQS Producer Queues.

SQSQueueConfig - Interface in com.atlassian.messagequeue.internal.sqs

Configuration for a Queue

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

Default Yaml config parser for sqs related config.

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

T

TENANT_DATA_ID_ATTRIBUTE_NAME - Static variable in class com.atlassian.messagequeue.internal.core.NestedMessageConstants

Stores an ID that is used to identify when a tenant's database is reset.

TENANT_ID_ATTRIBUTE_NAME - Static variable in class com.atlassian.messagequeue.internal.core.NestedMessageConstants

Stores an ID that uniquely identifies a tenant.

TenantDataIdSupplier - Interface in com.atlassian.messagequeue

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

Ensures that every message has a tenant id

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

toPayload(Message) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageInformationService

toPayload(Message) - Method in interface com.atlassian.messagequeue.MessageInformationService

Serializes the specified message into an atlassian-messagequeue formatted payload.

toString() - Method in class com.atlassian.messagequeue.MessageRunnerKey

toString() - Method in class com.atlassian.messagequeue.MessageValidatorKey

U

unregisterMessageRunner(MessageRunnerKey) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryService

unregisterMessageRunner(MessageRunnerKey) - Method in class com.atlassian.messagequeue.internal.inmemory.InMemoryMessageRunnerService

unregisterMessageRunner(MessageRunnerKey) - Method in interface com.atlassian.messagequeue.registry.MessageRunnerRegistryService

Unregister a message runner that has previously been registered on the key.

unregisterMessageValidator(MessageValidatorKey) - Method in class com.atlassian.messagequeue.internal.core.DefaultMessageValidatorRegistryService

unregisterMessageValidator(MessageValidatorKey) - Method in interface com.atlassian.messagequeue.registry.MessageValidatorRegistryService

Unregister a message validator that has previously been registered on the key.

W

withAmazonSQSClient(AmazonSQS) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withMessageInformationService(MessageInformationService) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withMessageRunnerRegistryHelper(MessageRunnerRegistryHelper) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withMessageValidatorRegistryHelper(MessageValidatorRegistryHelper) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withNestedMessageSerializer(NestedMessageSerializer) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withSqsMessageVisibilityTimeoutManager(SQSMessageVisibilityTimeoutManager) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withTenantContextProvider(TenantContextProvider<?>) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withTenantDataIdSupplier(TenantDataIdSupplier) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

withTenantIdSetter(TenantIdSetter) - Method in class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService.Builder

Y

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

Java object that represents SQS configuration in yaml config file

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

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

Java object that represents consumer queue config

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

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

Java object that represents message runner config

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

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

Java object that represents queue config

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

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

Java object that represents worker group config

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

A B C D E F G H I J M N O P R S T U W Y