Uses of Class
com.atlassian.messagequeue.MessageRunnerKey

Packages that use MessageRunnerKey

Package	Description
com.atlassian.messagequeue
com.atlassian.messagequeue.internal.core
com.atlassian.messagequeue.internal.inmemory
com.atlassian.messagequeue.registry	Package that handles the registration of MessageRunners under keys.

Uses of MessageRunnerKey in com.atlassian.messagequeue

Methods in com.atlassian.messagequeue that return MessageRunnerKey

Modifier and Type	Method and Description
MessageRunnerKey	Message.getRunnerKey() Returns the MessageRunnerKey which specifies a MessageRunner with which this Message should be handled by.
static MessageRunnerKey	MessageRunnerKey.of(String key) Wraps the provided string as a MessageRunnerKey.

Methods in com.atlassian.messagequeue with parameters of type MessageRunnerKey

Modifier and Type	Method and Description
static Message.Builder	Message.builder(MessageRunnerKey runnerKey) Builder factory method
int	MessageRunnerKey.compareTo(MessageRunnerKey o)
static Message	Message.create(MessageRunnerKey runnerKey, String payload) Message factory method
String	MessageInformationService.getQueueUrl(MessageRunnerKey messageRunnerKey) Returns the queue URL that atlassian-messagequeue is consuming from and producing to for the specified message runner key.

Constructors in com.atlassian.messagequeue with parameters of type MessageRunnerKey

Constructor and Description
InvalidMessagePayloadException(MessageRunnerKey messageRunnerKey, int invalidCodePoint) Constructs a new instance of invalid message payload exception.
MessagePayloadSizeExceededException(MessageRunnerKey key, long maxSize)
MessageRunnerNotRegisteredException(MessageRunnerKey key)

Uses of MessageRunnerKey in com.atlassian.messagequeue.internal.core

Methods in com.atlassian.messagequeue.internal.core with parameters of type MessageRunnerKey

Modifier and Type	Method and Description
Optional<MessageRunner>	MessageRunnerRegistryHelper.getMessageRunner(MessageRunnerKey messageRunnerKey) Retrieves the message runner registered against the specified key.
Optional<MessageRunner>	DefaultMessageRunnerRegistryService.getMessageRunner(MessageRunnerKey messageRunnerKey)
String	DefaultMessageInformationService.getQueueUrl(MessageRunnerKey messageRunnerKey)
void	DefaultMessageRunnerRegistryService.registerMessageRunner(MessageRunnerKey messageRunnerKey, MessageRunner messageRunner)
void	DefaultMessageRunnerRegistryService.unregisterMessageRunner(MessageRunnerKey messageRunnerKey)

Uses of MessageRunnerKey in com.atlassian.messagequeue.internal.inmemory

Methods in com.atlassian.messagequeue.internal.inmemory with parameters of type MessageRunnerKey

Modifier and Type	Method and Description
Optional<MessageRunner>	InMemoryMessageRunnerService.getMessageRunner(MessageRunnerKey messageRunnerKey)
void	InMemoryMessageRunnerService.registerMessageRunner(MessageRunnerKey messageRunnerKey, MessageRunner messageRunner)
void	InMemoryMessageRunnerService.unregisterMessageRunner(MessageRunnerKey messageRunnerKey)

Uses of MessageRunnerKey in com.atlassian.messagequeue.registry

Methods in com.atlassian.messagequeue.registry with parameters of type MessageRunnerKey

Modifier and Type	Method and Description
void	MessageRunnerRegistryService.registerMessageRunner(MessageRunnerKey messageRunnerKey, MessageRunner messageRunner) Register a message runner on the given key.
void	MessageRunnerRegistryService.unregisterMessageRunner(MessageRunnerKey messageRunnerKey) Unregister a message runner that has previously been registered on the key.