1 package com.atlassian.messagequeue.internal.core;
2
3 import com.atlassian.messagequeue.MessageRunnerKey;
4 import com.atlassian.messagequeue.registry.MessageRunner;
5
6 import java.util.Optional;
7
8 /**
9 * Allows <tt>MessageRunner</tt>s to be retrieved from the <tt>MessageRunnerRegistryService</tt>.
10 *
11 * <p>This interface provides method(s) that are useful for writing implementations of atlassian-messagequeue API.
12 */
13 public interface MessageRunnerRegistryHelper {
14 /**
15 * Retrieves the message runner registered against the specified key.
16 *
17 * @param messageRunnerKey the message runner key
18 * @return the message runner or none if not message runner has been registered against this key
19 */
20 Optional<MessageRunner> getMessageRunner(MessageRunnerKey messageRunnerKey);
21 }