Interface EdgeIndexTaskQueue
-
- All Known Implementing Classes:
JournalEdgeIndexTaskQueue
public interface EdgeIndexTaskQueue
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
enqueue(IndexTaskType indexTaskType, ContentEntityObject target)
Add a new task to this queue.void
enqueue(IndexTaskType indexTaskType, Edge edge)
Add a new task to this queue.long
getSize()
Retrieve the number of elements in the queue.void
processEntries(com.atlassian.fugue.Effect<EdgeIndexTask> action)
Apply the given action to contents of the queue.
-
-
-
Method Detail
-
enqueue
void enqueue(IndexTaskType indexTaskType, Edge edge)
Add a new task to this queue.
-
enqueue
void enqueue(IndexTaskType indexTaskType, ContentEntityObject target)
Add a new task to this queue.
-
getSize
long getSize()
Retrieve the number of elements in the queue.- Returns:
- size of the queue.
-
processEntries
void processEntries(com.atlassian.fugue.Effect<EdgeIndexTask> action)
Apply the given action to contents of the queue. Processing is stopped immediately if the action throws an exception when processing an element. Next call to processEntries will start from the failing element.- Parameters:
action
- action to apply queue contents
-
-