com.atlassian.messagequeue.internal.core

Class DefaultMessageValidatorRegistryService

java.lang.Object

com.atlassian.messagequeue.internal.core.DefaultMessageValidatorRegistryService

All Implemented Interfaces:

MessageValidatorRegistryHelper, MessageValidatorRegistryService

@ThreadSafe
public class DefaultMessageValidatorRegistryService
extends Object
implements MessageValidatorRegistryService, MessageValidatorRegistryHelper

A default message runner registry that stores registrations in memory in a concurrent data structure. It's important to realise that any validators registered here will only validate/filter messages received by the current node.

Constructor Summary

Constructors

Constructor and Description
DefaultMessageValidatorRegistryService()

Method Summary

Modifier and Type	Method and Description
Collection<MessageValidator>	getAllValidators() Retrieves all message validators.
void	registerMessageValidator(MessageValidatorKey messageRunnerKey, MessageValidator messageRunner) Register a message validator on the given key.
void	unregisterMessageValidator(MessageValidatorKey messageRunnerKey) Unregister a message validator 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

DefaultMessageValidatorRegistryService

public DefaultMessageValidatorRegistryService()

Method Detail

registerMessageValidator

public void registerMessageValidator(MessageValidatorKey messageRunnerKey,
                                     MessageValidator messageRunner)

Description copied from interface: MessageValidatorRegistryService

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

Specified by:

registerMessageValidator in interface MessageValidatorRegistryService

Parameters:

messageRunnerKey - unique message validator key

messageRunner - MessageValidator implementation

unregisterMessageValidator

public void unregisterMessageValidator(MessageValidatorKey messageRunnerKey)

Description copied from interface: MessageValidatorRegistryService

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

Specified by:

unregisterMessageValidator in interface MessageValidatorRegistryService

Parameters:

messageRunnerKey - unique message validator key

getAllValidators

public Collection<MessageValidator> getAllValidators()

Description copied from interface: MessageValidatorRegistryHelper

Retrieves all message validators.

Specified by:

getAllValidators in interface MessageValidatorRegistryHelper

Returns:

the message validators