public class IndexTaskProcessor extends Object
Constructor and Description |
---|
IndexTaskProcessor() |
Modifier and Type | Method and Description |
---|---|
ExecutorService |
getExecutorService()
Not sure if this is/should be used outside the class...
|
Queue<Future> |
getFutureQueue()
Get the list of index task futures submitted to the executor service.
|
void |
processFailedIndexTaskQueue()
Index the index task which currently has the failed status on the index task repository
|
void |
processIndexTaskQueue()
Start a round of IndexTask processing.
|
void |
processIndexTaskQueue(List<org.dataone.cn.index.task.IndexTask> queue)
Index the given index queue
|
void |
setSolrQueryUri(String uri) |
void |
shutdownExecutor()
Call at the end of processing, when canceled tasks would otherwise be left
in the IN PROCESS state.
|
public void processIndexTaskQueue()
public void processIndexTaskQueue(List<org.dataone.cn.index.task.IndexTask> queue)
queue
- public void processFailedIndexTaskQueue()
public void setSolrQueryUri(String uri)
public ExecutorService getExecutorService()
public Queue<Future> getFutureQueue()
public void shutdownExecutor()
Copyright © 2022. All rights reserved.