1 package com.atlassian.messagequeue.registry;
2
3 import com.atlassian.annotations.PublicApi;
4 import com.atlassian.messagequeue.MessageValidatorKey;
5
6 /**
7 * Interface for registering and unregistering message validators.
8 *
9 * @since 1.0.6
10 */
11 @PublicApi
12 public interface MessageValidatorRegistryService {
13
14 /**
15 * Register a message validator on the given key. Registering a new validator for the same key replaces the old validator.
16 * @param messageValidatorKey unique message validator key
17 * @param messageValidator MessageValidator implementation
18 */
19 void registerMessageValidator(MessageValidatorKey messageValidatorKey, MessageValidator messageValidator);
20
21 /**
22 * Unregister a message validator that has previously been registered on the key. If no runner is registered, logs a
23 * warning only.
24 * @param messageValidatorKey unique message validator key
25 */
26 void unregisterMessageValidator(MessageValidatorKey messageValidatorKey);
27 }