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 |
destroy() |
javax.jms.ConnectionFactory |
getConnectionFactory() |
String |
getConnectionFactoryName() |
org.kie.api.executor.ExecutorStoreService |
getExecutorStoreService() |
int |
getInterval() |
javax.jms.Queue |
getQueue() |
String |
getQueueName() |
int |
getRetries() |
int |
getThreadPoolSize() |
TimeUnit |
getTimeunit() |
void |
init() |
void |
init(ThreadFactory threadFactory) |
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 |
setQueue(javax.jms.Queue queue) |
void |
setQueueName(String queueName) |
void |
setRetries(int retries) |
void |
setThreadPoolSize(int threadPoolSize) |
void |
setTimeunit(TimeUnit timeunit) |
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 int getInterval()
getInterval
in interface org.kie.api.executor.Executor
public void setInterval(int interval)
setInterval
in interface org.kie.api.executor.Executor
public int getRetries()
getRetries
in interface org.kie.api.executor.Executor
public void setRetries(int retries)
setRetries
in interface org.kie.api.executor.Executor
public int getThreadPoolSize()
getThreadPoolSize
in interface org.kie.api.executor.Executor
public void setThreadPoolSize(int threadPoolSize)
setThreadPoolSize
in interface org.kie.api.executor.Executor
public TimeUnit getTimeunit()
getTimeunit
in interface org.kie.api.executor.Executor
public void setTimeunit(TimeUnit timeunit)
setTimeunit
in interface org.kie.api.executor.Executor
public void init()
init
in interface org.kie.api.executor.Executor
public void init(ThreadFactory threadFactory)
public void destroy()
destroy
in interface org.kie.api.executor.Executor
public Long scheduleRequest(String commandId, org.kie.api.executor.CommandContext ctx)
scheduleRequest
in interface org.kie.api.executor.Executor
public Long scheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)
scheduleRequest
in interface org.kie.api.executor.Executor
public void cancelRequest(Long requestId)
cancelRequest
in interface org.kie.api.executor.Executor
protected void sendMessage(String messageBody, int priority)
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.