public class IndexTaskServiceImpl extends java.lang.Object implements IndexTaskService
Modifier and Type | Class and Description |
---|---|
private class |
IndexTaskServiceImpl.ProviderMapper |
Modifier and Type | Field and Description |
---|---|
private AddProductsToIndexTaskProvider |
addProductsToIndexTaskProvider |
private CreateIndexTaskProvider |
createIndexTaskProvider |
private DeleteIndexTaskProvider |
deleteIndexTaskProvider |
private DeleteProductsFromIndexTaskProvider |
deleteProductsFromIndexTaskProvider |
private static org.slf4j.Logger |
log |
private TaskService |
taskService |
Constructor and Description |
---|
IndexTaskServiceImpl(TaskService taskService,
CreateIndexTaskProvider createIndexTaskProvider,
AddProductsToIndexTaskProvider addProductsToIndexTaskProvider,
DeleteProductsFromIndexTaskProvider deleteProductsFromIndexTaskProvider,
DeleteIndexTaskProvider deleteIndexTaskProvider) |
Modifier and Type | Method and Description |
---|---|
Task |
addTo(Index index,
java.util.List<IndexItem> items,
javax.ws.rs.core.UriInfo uriInfo)
Does require Synchronization if @see ConnectionProperties.isSlave() is true
|
Task |
create(Index index,
javax.ws.rs.core.UriInfo uriInfo)
Does require Synchronization if @see ConnectionProperties.isSlave() is true
|
Task |
deleteFrom(Index index,
java.util.List<IndexItem> items,
javax.ws.rs.core.UriInfo uriInfo)
Does not require any Synchronization
|
Task |
drop(Index index,
javax.ws.rs.core.UriInfo uriInfo)
Does not require any Synchronization
|
private void |
fillEPJTasks(java.util.List<Task> tasks) |
java.util.List<Task> |
recover() |
private Task |
submit(EPJTask task,
javax.ws.rs.core.UriInfo uriInfo) |
void |
submitRecovery(TaskExecutorConfiguration config,
RecoverEPJTasksTask recoverer) |
private static final org.slf4j.Logger log
private final TaskService taskService
private final CreateIndexTaskProvider createIndexTaskProvider
private final AddProductsToIndexTaskProvider addProductsToIndexTaskProvider
private final DeleteProductsFromIndexTaskProvider deleteProductsFromIndexTaskProvider
private final DeleteIndexTaskProvider deleteIndexTaskProvider
@Inject public IndexTaskServiceImpl(TaskService taskService, CreateIndexTaskProvider createIndexTaskProvider, AddProductsToIndexTaskProvider addProductsToIndexTaskProvider, DeleteProductsFromIndexTaskProvider deleteProductsFromIndexTaskProvider, DeleteIndexTaskProvider deleteIndexTaskProvider)
@Inject public void submitRecovery(TaskExecutorConfiguration config, RecoverEPJTasksTask recoverer)
public Task create(Index index, javax.ws.rs.core.UriInfo uriInfo)
IndexTaskService
create
in interface IndexTaskService
public Task addTo(Index index, java.util.List<IndexItem> items, javax.ws.rs.core.UriInfo uriInfo)
IndexTaskService
addTo
in interface IndexTaskService
public Task deleteFrom(Index index, java.util.List<IndexItem> items, javax.ws.rs.core.UriInfo uriInfo)
IndexTaskService
deleteFrom
in interface IndexTaskService
public Task drop(Index index, javax.ws.rs.core.UriInfo uriInfo)
IndexTaskService
drop
in interface IndexTaskService
public java.util.List<Task> recover()
recover
in interface IndexTaskService
private void fillEPJTasks(java.util.List<Task> tasks)