com.atlassian.messagequeue.internal.core

Class DefaultMessageInformationService

java.lang.Object

com.atlassian.messagequeue.internal.core.DefaultMessageInformationService

All Implemented Interfaces:

MessageInformationService

Direct Known Subclasses:

SQSMessageInformationService

public class DefaultMessageInformationService
extends Object
implements MessageInformationService

Message information service.

Constructor Summary

Constructors

Constructor and Description
DefaultMessageInformationService(String queueUrl, com.atlassian.tenant.api.TenantContextProvider tenantContextProvider, NestedMessageSerializer nestedMessageSerializer, TenantDataIdSupplier tenantDataIdSupplier)

Method Summary

Modifier and Type	Method and Description
Message	fromPayload(String payload) Deserializes a Message from the specified atlassian-messagequeue formatted payload.
String	getQueueUrl(MessageRunnerKey messageRunnerKey) Returns the queue URL that atlassian-messagequeue is consuming from and producing to for the specified message runner key.
String	toPayload(Message message) Serializes the specified message into an atlassian-messagequeue formatted payload.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMessageInformationService

public DefaultMessageInformationService(String queueUrl,
                                        com.atlassian.tenant.api.TenantContextProvider tenantContextProvider,
                                        NestedMessageSerializer nestedMessageSerializer,
                                        TenantDataIdSupplier tenantDataIdSupplier)

Parameters:

queueUrl - The URL that atlassian-messagequeue will be producing to and consuming from.

tenantContextProvider - the tenant context provider

nestedMessageSerializer - the nested message serializer

tenantDataIdSupplier - the tenant data id supplier

Method Detail

getQueueUrl

public String getQueueUrl(MessageRunnerKey messageRunnerKey)

Description copied from interface: MessageInformationService

Returns the queue URL that atlassian-messagequeue is consuming from and producing to for the specified message runner key.

Specified by:

getQueueUrl in interface MessageInformationService

Parameters:

messageRunnerKey - the message runner key

Returns:

the queue URL that atlassian-messagequeue is consuming from and producing to.

toPayload

public String toPayload(Message message)

Description copied from interface: MessageInformationService

Serializes the specified message into an atlassian-messagequeue formatted payload.

Specified by:

toPayload in interface MessageInformationService

Parameters:

message - the message

Returns:

the atlassian-messagequeue formatted payload

fromPayload

public Message fromPayload(String payload)

Description copied from interface: MessageInformationService

Deserializes a Message from the specified atlassian-messagequeue formatted payload.

Specified by:

fromPayload in interface MessageInformationService

Parameters:

payload - the atlassian-messagequeue formatted payload (cannot be null or empty)

Returns:

the message