Package org.redisson.executor
Class TasksRunnerService
-
- org.redisson.executor.TasksRunnerService
-
- All Implemented Interfaces:
RemoteExecutorService
public class TasksRunnerService extends implements RemoteExecutorService
Executor service runs Callable and Runnable tasks.- Author:
- Nikita Koksharov
-
-
Constructor Summary
Constructors Constructor Description TasksRunnerService(CommandAsyncExecutor commandExecutor, RedissonClient redisson, Codec codec, name, <,ResponseEntry> responses)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description executeCallable(TaskParameters params)
void
executeRunnable(TaskParameters params)
void
executeRunnable(TaskParameters params, boolean removeTask)
protected >
requestId)
void
schedule(ScheduledCronExpressionParameters params)
void
scheduleAtFixedRate(ScheduledAtFixedRateParameters params)
scheduleCallable(ScheduledParameters params)
protected void
requestId, retryInterval)
void
scheduleRunnable(ScheduledParameters params)
void
scheduleWithFixedDelay(ScheduledWithFixedDelayParameters params)
void
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void
schedulerChannelName)
void
schedulerQueueName)
void
statusName)
void
tasksCounterName)
void
tasksExpirationTimeName)
void
tasksName)
void
tasksRetryInterval)
void
terminationTopicName)
-
-
-
Constructor Detail
-
TasksRunnerService
public TasksRunnerService(CommandAsyncExecutor commandExecutor, RedissonClient redisson, Codec codec, name, <,ResponseEntry> responses)
-
-
Method Detail
-
setBeanFactory
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
-
setTasksExpirationTimeName
public void setTasksExpirationTimeName( tasksExpirationTimeName)
-
setTasksRetryIntervalName
public void setTasksRetryIntervalName( tasksRetryInterval)
-
setSchedulerQueueName
public void setSchedulerQueueName( schedulerQueueName)
-
setSchedulerChannelName
public void setSchedulerChannelName( schedulerChannelName)
-
setTasksName
public void setTasksName( tasksName)
-
setTasksCounterName
public void setTasksCounterName( tasksCounterName)
-
setStatusName
public void setStatusName( statusName)
-
setTerminationTopicName
public void setTerminationTopicName( terminationTopicName)
-
scheduleAtFixedRate
public void scheduleAtFixedRate(ScheduledAtFixedRateParameters params)
- Specified by:
scheduleAtFixedRate
in interfaceRemoteExecutorService
-
schedule
public void schedule(ScheduledCronExpressionParameters params)
- Specified by:
schedule
in interfaceRemoteExecutorService
-
scheduleWithFixedDelay
public void scheduleWithFixedDelay(ScheduledWithFixedDelayParameters params)
- Specified by:
scheduleWithFixedDelay
in interfaceRemoteExecutorService
-
scheduleCallable
public scheduleCallable(ScheduledParameters params)
- Specified by:
scheduleCallable
in interfaceRemoteExecutorService
-
scheduleRunnable
public void scheduleRunnable(ScheduledParameters params)
- Specified by:
scheduleRunnable
in interfaceRemoteExecutorService
-
executeCallable
public executeCallable(TaskParameters params)
- Specified by:
executeCallable
in interfaceRemoteExecutorService
-
scheduleRetryTimeRenewal
protected void scheduleRetryTimeRenewal( requestId, retryInterval)
-
renewRetryTime
protected > renewRetryTime( requestId)
-
executeRunnable
public void executeRunnable(TaskParameters params, boolean removeTask)
-
executeRunnable
public void executeRunnable(TaskParameters params)
- Specified by:
executeRunnable
in interfaceRemoteExecutorService
-
-