public class ExecutorImpl extends Object implements org.kie.internal.executor.api.Executor
Executor that is baced by
ScheduledExecutorService for background task execution.
It can be configured for following:
| Constructor and Description |
|---|
ExecutorImpl() |
| Modifier and Type | Method and Description |
|---|---|
void |
cancelRequest(Long requestId) |
void |
clearExecution(Long requestId) |
void |
destroy() |
protected ClassLoader |
getClassLoader(String deploymentId) |
javax.jms.ConnectionFactory |
getConnectionFactory() |
String |
getConnectionFactoryName() |
protected String |
getDeploymentId(org.kie.api.executor.CommandContext ctx) |
org.kie.api.executor.ExecutorStoreService |
getExecutorStoreService() |
int |
getInterval() |
AvailableJobsExecutor |
getJobProcessor() |
javax.jms.Queue |
getQueue() |
String |
getQueueName() |
int |
getRetries() |
protected ScheduledExecutorService |
getScheduledExecutorService() |
int |
getThreadPoolSize() |
TimeUnit |
getTimeunit() |
org.drools.persistence.api.TransactionManager |
getTransactionManager() |
void |
init() |
void |
markAsPendingRetryRequest(Long requestId) |
Consumer<Object> |
scheduleExecution(RequestInfo requestInfo,
Date date) |
void |
scheduleExecutionViaSync(RequestInfo requestInfo,
Date date) |
Long |
scheduleRequest(String commandId,
org.kie.api.executor.CommandContext ctx) |
Long |
scheduleRequest(String commandId,
Date date,
org.kie.api.executor.CommandContext ctx) |
protected void |
sendMessage(String messageBody,
int priority) |
void |
setConnectionFactory(javax.jms.ConnectionFactory connectionFactory) |
void |
setConnectionFactoryName(String connectionFactoryName) |
void |
setEventSupport(ExecutorEventSupport eventSupport) |
void |
setExecutorStoreService(org.kie.api.executor.ExecutorStoreService executorStoreService) |
void |
setInterval(int interval) |
void |
setJobProcessor(AvailableJobsExecutor jobProcessor) |
void |
setQueue(javax.jms.Queue queue) |
void |
setQueueName(String queueName) |
void |
setRetries(int retries) |
void |
setThreadPoolSize(int threadPoolSize) |
void |
setTimeunit(TimeUnit timeunit) |
void |
setTransactionManager(org.drools.persistence.api.TransactionManager transactionManager) |
void |
updateRequestData(Long requestId,
Map<String,Object> data) |
public void setEventSupport(ExecutorEventSupport eventSupport)
public void setExecutorStoreService(org.kie.api.executor.ExecutorStoreService executorStoreService)
public org.kie.api.executor.ExecutorStoreService getExecutorStoreService()
public String getConnectionFactoryName()
public void setConnectionFactoryName(String connectionFactoryName)
public String getQueueName()
public void setQueueName(String queueName)
public javax.jms.ConnectionFactory getConnectionFactory()
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
public javax.jms.Queue getQueue()
public void setQueue(javax.jms.Queue queue)
public AvailableJobsExecutor getJobProcessor()
public void setJobProcessor(AvailableJobsExecutor jobProcessor)
public org.drools.persistence.api.TransactionManager getTransactionManager()
public void setTransactionManager(org.drools.persistence.api.TransactionManager transactionManager)
public int getInterval()
getInterval in interface org.kie.api.executor.Executorpublic void setInterval(int interval)
setInterval in interface org.kie.api.executor.Executorpublic int getRetries()
getRetries in interface org.kie.api.executor.Executorpublic void setRetries(int retries)
setRetries in interface org.kie.api.executor.Executorpublic int getThreadPoolSize()
getThreadPoolSize in interface org.kie.api.executor.Executorpublic void setThreadPoolSize(int threadPoolSize)
setThreadPoolSize in interface org.kie.api.executor.Executorpublic TimeUnit getTimeunit()
getTimeunit in interface org.kie.api.executor.Executorpublic void setTimeunit(TimeUnit timeunit)
setTimeunit in interface org.kie.api.executor.Executorpublic void init()
init in interface org.kie.api.executor.Executorpublic void destroy()
destroy in interface org.kie.api.executor.Executorpublic Long scheduleRequest(String commandId, org.kie.api.executor.CommandContext ctx)
scheduleRequest in interface org.kie.api.executor.Executorpublic Long scheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)
scheduleRequest in interface org.kie.api.executor.Executorpublic Consumer<Object> scheduleExecution(RequestInfo requestInfo, Date date)
public void scheduleExecutionViaSync(RequestInfo requestInfo, Date date)
public void clearExecution(Long requestId)
public void cancelRequest(Long requestId)
cancelRequest in interface org.kie.api.executor.Executorpublic void markAsPendingRetryRequest(Long requestId)
public void updateRequestData(Long requestId, Map<String,Object> data)
updateRequestData in interface org.kie.api.executor.Executorprotected void sendMessage(String messageBody, int priority)
protected ClassLoader getClassLoader(String deploymentId)
protected ScheduledExecutorService getScheduledExecutorService()
protected String getDeploymentId(org.kie.api.executor.CommandContext ctx)
Copyright © 2001–2021 JBoss by Red Hat. All rights reserved.