public interface IQueue
Queue implementation flow:
take() message from queue.finish(IQueueMessage).requeue(IQueueMessage) or
requeueSilent(IQueueMessage) to requeue the message.| Modifier and Type | Method and Description |
|---|---|
int |
ephemeralSize()
Gets ephemeral-storage's number of items.
|
void |
finish(IQueueMessage msg)
Called when finish processing the message to cleanup ephemeral storage.
|
Collection<IQueueMessage> |
getOrphanMessages(long thresholdTimestampMs)
Gets all orphan messages (messages that were left in ephemeral storage
for a long time).
|
boolean |
moveFromEphemeralToQueueStorage(IQueueMessage msg)
Moves a message from ephemeral back to queue storage.
|
boolean |
queue(IQueueMessage msg)
Queues a message.
|
int |
queueSize()
Gets queue's number of items.
|
boolean |
requeue(IQueueMessage msg)
Re-queues a message.
|
boolean |
requeueSilent(IQueueMessage msg)
Silently re-queues a message.
|
IQueueMessage |
take()
Takes a message out of queue.
|
boolean queue(IQueueMessage msg)
Implementation flow:
msg - boolean requeue(IQueueMessage msg)
Implementation flow:
Note: ephemeral storage implementation is optional, depends on implementation.
msg - boolean requeueSilent(IQueueMessage msg)
Implementation flow:
Note: ephemeral storage implementation is optional, depends on implementation.
msg - void finish(IQueueMessage msg)
Implementation flow:
Note: ephemeral storage implementation is optional, depends on implementation.
msg - IQueueMessage take()
Implementation flow:
Note: ephemeral storage implementation is optional, depends on implementation.
Collection<IQueueMessage> getOrphanMessages(long thresholdTimestampMs)
thresholdTimestampMs - get all orphan messages that were queued
before this timestampboolean moveFromEphemeralToQueueStorage(IQueueMessage msg)
Implementation flow:
msg - true if a move has been made, false otherwise
(e.g. the message didn't exist in ephemeral storage)int queueSize()
int ephemeralSize()
Note: ephemeral storage implementation is optional, depends on implementation.
Copyright © 2015 DDTH. All Rights Reserved.