| Package | Description |
|---|---|
| com.atlassian.messagequeue.internal.core | |
| com.atlassian.messagequeue.internal.inmemory | |
| com.atlassian.messagequeue.internal.scheduler | |
| com.atlassian.messagequeue.internal.sqs |
SQS-specific message runner support.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultMessageRunnerRegistryService
A default message runner registry that stores registrations in memory in a concurrent data structure.
|
| Constructor and Description |
|---|
NestedMessageConsumer(MessageRunnerRegistryHelper messageRunnerRegistryHelper,
com.atlassian.tenant.impl.TenantIdSetter tenantIdSetter,
MessageValidatorRegistryHelper messageValidatorRegistryHelper)
Constructs an instance of
NestedMessageConsumer. |
| Modifier and Type | Class and Description |
|---|---|
class |
InMemoryMessageRunnerService
Implementation of both
MessageRunnerService and MessageRunnerRegistryService. |
| Constructor and Description |
|---|
SchedulerMessageRunnerService(com.atlassian.scheduler.SchedulerService schedulerService,
MessageRunnerRegistryHelper messageRunnerRegistryHelper,
MessageInformationService messageInformationService,
NestedMessageSerializer nestedMessageSerializer)
Constructs a new instance of SchedulerMessageRunnerService.
|
SchedulerMessageRunnerService(com.atlassian.scheduler.SchedulerService schedulerService,
MessageRunnerRegistryHelper messageRunnerRegistryHelper,
MessageInformationService messageInformationService,
NestedMessageSerializer nestedMessageSerializer,
long deliveryIntervalMillis,
int maxDeliveryCount)
Constructs a new instance of SchedulerMessageRunnerService.
|
| Modifier and Type | Method and Description |
|---|---|
SQSMessageRunnerService.Builder |
SQSMessageRunnerService.Builder.withMessageRunnerRegistryHelper(MessageRunnerRegistryHelper messageRunnerRegistryHelper) |
Copyright © 2017 Atlassian. All rights reserved.