com.atlassian.messagequeue.internal.core

Class DefaultMessageRunnerRegistryService

java.lang.Object

com.atlassian.messagequeue.internal.core.DefaultMessageRunnerRegistryService

All Implemented Interfaces:

MessageRunnerRegistryHelper, MessageRunnerRegistryService

@ThreadSafe
public class DefaultMessageRunnerRegistryService
extends Object
implements MessageRunnerRegistryService, MessageRunnerRegistryHelper

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

Constructor Summary

Constructors

Constructor and Description
DefaultMessageRunnerRegistryService()

Method Summary

Modifier and Type	Method and Description
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

DefaultMessageRunnerRegistryService

public DefaultMessageRunnerRegistryService()

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

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