com.atlassian.messagequeue.internal.core

Class NestedMessageConsumer

java.lang.Object

com.atlassian.messagequeue.internal.core.NestedMessageConsumer

public class NestedMessageConsumer
extends Object

Consumes a NestedMessage.

Field Summary

Fields

Modifier and Type	Field and Description
static String	MDC_MESSAGE_RUNNER_KEY

Constructor Summary

Constructors

Constructor and Description
NestedMessageConsumer(MessageRunnerRegistryHelper messageRunnerRegistryHelper, com.atlassian.tenant.impl.TenantIdSetter tenantIdSetter, MessageValidatorRegistryHelper messageValidatorRegistryHelper) Constructs an instance of NestedMessageConsumer.

Method Summary

Modifier and Type	Method and Description
void	consume(NestedMessage nestedMessage, MessageContext messageContext) Consumes a NestedMessage.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MDC_MESSAGE_RUNNER_KEY

public static final String MDC_MESSAGE_RUNNER_KEY

See Also:

Constant Field Values

Constructor Detail

NestedMessageConsumer

public NestedMessageConsumer(MessageRunnerRegistryHelper messageRunnerRegistryHelper,
                             com.atlassian.tenant.impl.TenantIdSetter tenantIdSetter,
                             MessageValidatorRegistryHelper messageValidatorRegistryHelper)

Constructs an instance of NestedMessageConsumer.

Parameters:

messageRunnerRegistryHelper - the message runner registry helper

tenantIdSetter - the tenant ID setter

messageValidatorRegistryHelper - a helper to get all message validators

Method Detail

consume

public void consume(NestedMessage nestedMessage,
                    MessageContext messageContext)

Consumes a NestedMessage.

Parameters:

nestedMessage - the nested message

messageContext - the message context