Interface EdgeIndexTaskQueue

All Known Implementing Classes:
JournalEdgeIndexTaskQueue

public interface EdgeIndexTaskQueue
  • Method Details

    • 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.
    • enqueue

      void enqueue(IndexTaskType indexTaskType, RebuildIndexTask.RebuildIndexParams rebuildIndexParams)
      Adds a RebuildIndexTask to the the 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