com.atlassian.messagequeue.registry

Interface MessageRunnerRegistryService

@PublicApi
public interface MessageRunnerRegistryService

Interface for registering and unregistering message runners.

Since:

1.0

Method Summary

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

Method Detail

registerMessageRunner

void registerMessageRunner(MessageRunnerKey messageRunnerKey,
                           MessageRunner messageRunner)

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

Parameters:

messageRunnerKey - unique message runner key

messageRunner - MessageRunner implementation

unregisterMessageRunner

void unregisterMessageRunner(MessageRunnerKey messageRunnerKey)

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

Parameters:

messageRunnerKey - unique message runner key