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) 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)

Constructs an instance of NestedMessageConsumer.

Parameters:

messageRunnerRegistryHelper - the message runner registry helper

tenantIdSetter - the tenant ID setter

Method Detail

consume

public void consume(NestedMessage nestedMessage,
                    MessageContext messageContext)

Consumes a NestedMessage.

Parameters:

nestedMessage - the nested message

messageContext - the message context