Modifier and Type | Method and Description |
---|---|
static void |
DistributionPackageUtils.mergeQueueEntry(DistributionPackageInfo packageInfo,
DistributionQueueEntry entry) |
Modifier and Type | Method and Description |
---|---|
DistributionQueueEntry |
DistributionQueueWrapper.add(@NotNull DistributionQueueItem item) |
DistributionQueueEntry |
CachingDistributionQueue.add(@NotNull DistributionQueueItem item) |
DistributionQueueEntry |
DistributionQueueWrapper.getEntry(@NotNull String itemId) |
DistributionQueueEntry |
DistributionQueueWrapper.getHead() |
DistributionQueueEntry |
DistributionQueueWrapper.remove(@NotNull String itemId) |
DistributionQueueEntry |
CachingDistributionQueue.remove(@NotNull String itemId) |
Modifier and Type | Method and Description |
---|---|
boolean |
DistributionQueueProcessor.process(@NotNull String queueName,
@NotNull DistributionQueueEntry queueEntry)
Process an item from a certain
DistributionQueue |
Modifier and Type | Method and Description |
---|---|
DistributionQueueEntry |
JobHandlingDistributionQueue.add(@NotNull DistributionQueueItem item) |
DistributionQueueEntry |
JobHandlingDistributionQueue.getEntry(@NotNull String id) |
DistributionQueueEntry |
JobHandlingDistributionQueue.getHead() |
DistributionQueueEntry |
JobHandlingDistributionQueue.remove(@NotNull String id) |
Modifier and Type | Method and Description |
---|---|
@Nullable DistributionQueueEntry |
ResourceQueue.add(@NotNull DistributionQueueItem item) |
@Nullable DistributionQueueEntry |
ResourceQueue.getEntry(@NotNull String itemId) |
DistributionQueueEntry |
ResourceQueue.getHead() |
@Nullable DistributionQueueEntry |
ResourceQueue.remove(@NotNull String itemId) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveResourceQueue.recordProcessingAttempt(@NotNull DistributionQueueEntry entry) |
Modifier and Type | Method and Description |
---|---|
DistributionQueueEntry |
SimpleDistributionQueue.add(@NotNull DistributionQueueItem item) |
@Nullable DistributionQueueEntry |
SimpleDistributionQueue.getEntry(@NotNull String id) |
@Nullable DistributionQueueEntry |
SimpleDistributionQueue.getHead() |
@Nullable DistributionQueueEntry |
SimpleDistributionQueue.remove(@NotNull String id) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleDistributionQueue.recordProcessingAttempt(@NotNull DistributionQueueEntry entry) |
Constructor and Description |
---|
SimpleDistributionQueueProcessor(DistributionQueue queue,
DistributionQueueProcessor queueProcessor,
Consumer<DistributionQueueEntry> processingAttemptRecorder) |
Modifier and Type | Method and Description |
---|---|
@Nullable DistributionQueueEntry |
DistributionQueue.add(@NotNull DistributionQueueItem item)
add a distribution item to this queue
|
@Nullable DistributionQueueEntry |
DistributionQueue.getEntry(@NotNull String entryId)
gets an entry from the queue by specifying its id
|
@Nullable DistributionQueueEntry |
DistributionQueue.getHead()
get the first entry (in a FIFO strategy, the next to be processed) from the queue
|
@Nullable DistributionQueueEntry |
DistributionQueue.remove(@NotNull String entryId)
remove an entry from the queue by specifying its id
|
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.