Interface EdgeIndexTaskQueue

    • Method Detail

      • enqueue

        void enqueue​(IndexTaskType indexTaskType,
                     Edge edge)
        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