com.atlassian.messagequeue.registry

Interface MessageValidator

All Known Implementing Classes:

MessageRunnerKeyValidator, TenantIdKeyValidator

@PublicApi
public interface MessageValidator

Provides a mechanism to validate or filter messages based on their attributes and context.

Since:

1.0.6

Method Summary

Modifier and Type	Method and Description
void	handleInvalidMessage(MessageContext messageContext, Map<String,String> messageAttributes) handleInvalidMessage is called for any message that fails isValid.
boolean	isValid(MessageContext messageContext, Map<String,String> messageAttributes) Is the message valid? If not then the message will not be processed by its message runner, and handleInvalidMessage will be called.

Method Detail

isValid

boolean isValid(MessageContext messageContext,
                Map<String,String> messageAttributes)

Is the message valid? If not then the message will not be processed by its message runner, and handleInvalidMessage will be called.

Parameters:

messageContext - the message context

messageAttributes - an immutable map of the message's attributes

Returns:

boolean validity of the message

handleInvalidMessage

void handleInvalidMessage(MessageContext messageContext,
                          Map<String,String> messageAttributes)

handleInvalidMessage is called for any message that fails isValid.

Parameters:

messageContext - the message context

messageAttributes - an immutable map of the message's attributes