com.atlassian.messagequeue.internal.sqs

Class SQSMessageRunnerService

java.lang.Object

com.atlassian.messagequeue.internal.sqs.SQSMessageRunnerService

All Implemented Interfaces:

MessageRunnerService

public class SQSMessageRunnerService
extends Object
implements MessageRunnerService

SQS message runner service that produces messages onto an SQS queue and manages a pool of threads that consume from said queue.

To properly initialise an instance of this service, a client must call initialiseMessageConsumers() after constructing an instance (or else ensure the dependency injection framework will automatically invoke methods annotated with @PostConstruct).

To properly dispose of an instance of this service, a client must call shutdown() (or else ensure the dependency injection framework will automatically invoke methods annotated with @PreDestroy).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SQSMessageRunnerService.Builder A builder to help make the SQSMessageRunnerService.

Method Summary

Modifier and Type	Method and Description
void	addMessage(Message message) Adds a message that will be executed at some future point.
void	initialiseMessageConsumers()
static SQSMessageRunnerService.Builder	newBuilder(SQSMessageRunnerKeyToProducerMapper messageRunnerKeyToProducerMapper, Set<SQSConsumerQueueConfig> consumerQueueConfigs) Create a new SQSMessageRunnerService builder
void	shutdown()

Methods inherited from class java.lang.Object

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

Method Detail

initialiseMessageConsumers

public void initialiseMessageConsumers()

shutdown

@PreDestroy
public void shutdown()

addMessage

public void addMessage(@Nonnull
                       Message message)

Description copied from interface: MessageRunnerService

Adds a message that will be executed at some future point. Messages may not be executed in the order in which they are added.

Specified by:

addMessage in interface MessageRunnerService

Parameters:

message - message specification

newBuilder

public static SQSMessageRunnerService.Builder newBuilder(SQSMessageRunnerKeyToProducerMapper messageRunnerKeyToProducerMapper,
                                                         Set<SQSConsumerQueueConfig> consumerQueueConfigs)

Create a new SQSMessageRunnerService builder

Parameters:

messageRunnerKeyToProducerMapper - mapping from MessageRunnerKeys to SQSProducerQueueConfigs

consumerQueueConfigs - all SQSConsumerQueueConfigs should be listened to.

Since:

2.1.0