com.atlassian.messagequeue.internal.sqs

Class SQSMessageInformationService

java.lang.Object

com.atlassian.messagequeue.internal.core.DefaultMessageInformationService

com.atlassian.messagequeue.internal.sqs.SQSMessageInformationService

All Implemented Interfaces:

MessageInformationService

public class SQSMessageInformationService
extends DefaultMessageInformationService

SQS variant of DefaultMessageInformationService. This provides a method to obtain SQS queue URLs

Since:

2.1.0

Constructor Summary

Constructors

Constructor and Description
SQSMessageInformationService(SQSMessageRunnerKeyToProducerMapper messageRunnerKeyToProducerMapper, com.atlassian.tenant.api.TenantContextProvider tenantContextProvider, NestedMessageSerializer nestedMessageSerializer, TenantDataIdSupplier tenantDataIdSupplier)

Method Summary

Modifier and Type	Method and Description
String	getQueueUrl(MessageRunnerKey messageRunnerKey) Returns the queue URL that atlassian-messagequeue is consuming from and producing to for the specified message runner key.

Methods inherited from class com.atlassian.messagequeue.internal.core.DefaultMessageInformationService

fromPayload, toPayload

Methods inherited from class java.lang.Object

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

Constructor Detail

SQSMessageInformationService

public SQSMessageInformationService(SQSMessageRunnerKeyToProducerMapper messageRunnerKeyToProducerMapper,
                                    com.atlassian.tenant.api.TenantContextProvider tenantContextProvider,
                                    NestedMessageSerializer nestedMessageSerializer,
                                    TenantDataIdSupplier tenantDataIdSupplier)

Parameters:

messageRunnerKeyToProducerMapper - mapping from messageRunnerKey to queue config

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

Overrides:

getQueueUrl in class DefaultMessageInformationService

Parameters:

messageRunnerKey - the message runner key

Returns:

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