com.atlassian.messagequeue.internal.inmemory

Class InMemoryMessageRunnerService

java.lang.Object

com.atlassian.messagequeue.internal.inmemory.InMemoryMessageRunnerService

All Implemented Interfaces:

MessageRunnerRegistryHelper, MessageRunnerService, MessageRunnerRegistryService

public class InMemoryMessageRunnerService
extends Object
implements MessageRunnerService, MessageRunnerRegistryService, MessageRunnerRegistryHelper

Implementation of both MessageRunnerService and MessageRunnerRegistryService. Messages are stored in-memory.

Constructor Summary

Constructors

Constructor and Description
InMemoryMessageRunnerService(ExecutorService executorService)

Method Summary

Modifier and Type	Method and Description
void	addMessage(Message message) Adds a message that will be executed at some future point.
Optional<MessageRunner>	getMessageRunner(MessageRunnerKey messageRunnerKey) Retrieves the message runner registered against the specified key.
void	registerMessageRunner(MessageRunnerKey messageRunnerKey, MessageRunner messageRunner) Register a message runner on the given key.
void	unregisterMessageRunner(MessageRunnerKey messageRunnerKey) Unregister a message runner that has previously been registered on the key.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryMessageRunnerService

public InMemoryMessageRunnerService(ExecutorService executorService)

Method Detail

registerMessageRunner

public void registerMessageRunner(MessageRunnerKey messageRunnerKey,
                                  MessageRunner messageRunner)

Description copied from interface: MessageRunnerRegistryService

Register a message runner on the given key. Registering a new runner for the same key replaces the old runner.

Specified by:

registerMessageRunner in interface MessageRunnerRegistryService

Parameters:

messageRunnerKey - unique message runner key

messageRunner - MessageRunner implementation

unregisterMessageRunner

public void unregisterMessageRunner(MessageRunnerKey messageRunnerKey)

Description copied from interface: MessageRunnerRegistryService

Unregister a message runner that has previously been registered on the key. If no runner is registered, logs a warning only.

Specified by:

unregisterMessageRunner in interface MessageRunnerRegistryService

Parameters:

messageRunnerKey - unique message runner key

addMessage

public void addMessage(Message message)

Description copied from interface: MessageRunnerService

Adds a message that will be executed at some future point. Messages may not be executed in the order in which they are added.

Specified by:

addMessage in interface MessageRunnerService

Parameters:

message - message specification

getMessageRunner

public Optional<MessageRunner> getMessageRunner(MessageRunnerKey messageRunnerKey)

Description copied from interface: MessageRunnerRegistryHelper

Retrieves the message runner registered against the specified key.

Specified by:

getMessageRunner in interface MessageRunnerRegistryHelper

Parameters:

messageRunnerKey - the message runner key

Returns:

the message runner or none if not message runner has been registered against this key