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

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

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.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.inmemory - package com.atlassian.messagequeue.internal.inmemory

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.registry - package com.atlassian.messagequeue.registry

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

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

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

Message information service.

DefaultMessageInformationService(String, TenantContextProvider, NestedMessageSerializer) - 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

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.

E

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

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

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

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

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

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

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

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.

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

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

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

I

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

Initialises this instance.

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

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.

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

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

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.

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) - 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.

O

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

Wraps the provided string as a MessageRunnerKey.

P

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.

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.

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

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.scheduler.SchedulerMessageRunnerService

Shuts down this instance.

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

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(AmazonSQSClient, String, MessageRunnerRegistryHelper, TenantIdSetter, MessageInformationService, NestedMessageSerializer) - Constructor for class com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService

T

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

Stores an ID that uniquely identifies a tenant.

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

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.

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