@FieldsAreNonnullByDefault @ParametersAreNonnullByDefault @ReturnValuesAreNonnullByDefault

Package com.atlassian.messagequeue.registry

Package that handles the registration of MessageRunners under keys.

See: Description

Interface Summary

Interface	Description
MessageContext	Context that is passed to an execution of a message.
MessageRunner	Message Runner SPI.
MessageRunnerRegistryService	Interface for registering and unregistering message runners.
MessageValidator	Provides a mechanism to validate or filter messages based on their attributes and context.
MessageValidatorRegistryService	Interface for registering and unregistering message validators.

Package com.atlassian.messagequeue.registry Description

Package that handles the registration of MessageRunners under keys.

Once a MessageRunner has been registered, all access to the runner is via the corresponding MessageRunnerKey

     public static final MessageRunnerKey MESSAGE_RUNNER_KEY = MessageRunnerKey.of("export-space");

     public ExportSpaceMessageRunnerFactory() {
        messageRegistryService.registerMessageRunner(MESSAGE_RUNNER_KEY, new ExportSpaceMessageRunner());
     }

     private static class ExportSpaceMessageRunner() {
         {@literal @}Override
         public void processMessage(MessageContext messageContext) {
             Optional<String> payload = messageContext.getPayload();
             // deserialize payload and do some message ...
         }
     }
 

Since:

1.0