com.atlassian.messagequeue.registry

Interface MessageRunner

@PublicSpi
public interface MessageRunner

Message Runner SPI. Implementations of Message Runners should implement this interface.

Since:

1.0

Method Summary

Modifier and Type	Method and Description
void	processMessage(MessageContext context) Entry point for running this message.

Method Detail

processMessage

void processMessage(MessageContext context)

Entry point for running this message.

A WorkContext and tenant context (as per the workcontext api) will be established before handleMessage() is called. This workcontext will be forcibly torn down when handleMessage() returns.

To signify success or failure, a message should communicate via some token in its payload - eg the ID of a DB record.

If an exception is thrown by an implementor of this method, the message system may retry processing the message later. Whether retries are attempted, the number of retries, and the interval between retries is up to the configuration of the MessageRunnerService implementation.

Parameters:

context - Message execution context