Package com.netgrif.application.engine.elastic.service

Class ElasticTaskQueueManager

java.lang.Object

com.netgrif.application.engine.elastic.service.ElasticTaskQueueManager

@Service
public class ElasticTaskQueueManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
ElasticTaskQueueManager(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor elasticTaskExecutor, ElasticTaskRepository repository)

Method Summary

Modifier and Type	Method	Description
void	destroy()
void	removeTasksByProcess(java.lang.String processId)
java.util.concurrent.Future<ElasticTask>	scheduleOperation(ElasticTaskJob task)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ElasticTaskQueueManager

public ElasticTaskQueueManager(@Qualifier("elasticTaskExecutor")
                               org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor elasticTaskExecutor,
                               ElasticTaskRepository repository)

Method Detail

scheduleOperation

public java.util.concurrent.Future<ElasticTask> scheduleOperation(ElasticTaskJob task)

destroy

@PreDestroy
public void destroy()
             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

removeTasksByProcess

public void removeTasksByProcess(java.lang.String processId)