com.atlassian.messagequeue.internal.sqs

Class DefaultSQSMessageRunnerKeyToProducerMapper

java.lang.Object

com.atlassian.messagequeue.internal.sqs.DefaultSQSMessageRunnerKeyToProducerMapper

All Implemented Interfaces:

SQSMessageRunnerKeyToProducerMapper

public class DefaultSQSMessageRunnerKeyToProducerMapper
extends Object
implements SQSMessageRunnerKeyToProducerMapper

Default implementation of SQSMessageRunnerKeyToProducerMapper Return SQSProducerQueueConfig for provided MessageRunnerKey from the map or default one if MessageRunnerKey is not in the map

Constructor Summary

Constructors

Constructor and Description
DefaultSQSMessageRunnerKeyToProducerMapper(SQSConfig sqsConfig)

Method Summary

Modifier and Type	Method and Description
SQSProducerQueueConfig	getQueueConfigForMessageRunner(MessageRunnerKey messageRunnerKey)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSQSMessageRunnerKeyToProducerMapper

public DefaultSQSMessageRunnerKeyToProducerMapper(SQSConfig sqsConfig)

Method Detail

getQueueConfigForMessageRunner

public SQSProducerQueueConfig getQueueConfigForMessageRunner(MessageRunnerKey messageRunnerKey)

Specified by:

getQueueConfigForMessageRunner in interface SQSMessageRunnerKeyToProducerMapper