Package org.redisson.executor

Class TasksService

java.lang.Object

org.redisson.remote.BaseRemoteService

org.redisson.executor.TasksService

Direct Known Subclasses:

ScheduledTasksService, TasksBatchService

public class TasksService
extends BaseRemoteService

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
protected String	schedulerChannelName
protected String	schedulerQueueName
protected String	statusName
protected String	tasksCounterName
protected String	tasksExpirationTimeName
protected String	tasksName
protected long	tasksRetryInterval
protected String	tasksRetryIntervalName
protected String	terminationTopicName

Fields inherited from class org.redisson.remote.BaseRemoteService

cancelRequestMapName, cancelResponseMapName, codec, commandExecutor, executorId, name, responseQueueName

Constructor Summary

Constructors

Constructor	Description
TasksService(Codec codec, String name, CommandAsyncExecutor commandExecutor, String executorId, ConcurrentMap<String,ResponseEntry> responses)

Method Summary

Modifier and Type	Method	Description
protected RFuture<Boolean>	addAsync(String requestQueueName, RemoteServiceRequest request)
protected RFuture<Boolean>	addAsync(String requestQueueName, RemoteServiceRequest request, RemotePromise<Object> result)
RFuture<Boolean>	cancelExecutionAsync(RequestId requestId)
protected RequestId	generateRequestId()
protected CommandAsyncExecutor	getAddCommandExecutor()
RFuture<Boolean>	hasTaskAsync(String taskId)
protected RFuture<Boolean>	removeAsync(String requestQueueName, RequestId taskId)
void	setSchedulerChannelName(String schedulerChannelName)
void	setSchedulerQueueName(String scheduledQueueName)
void	setStatusName(String statusName)
void	setTasksCounterName(String tasksCounterName)
void	setTasksExpirationTimeName(String tasksExpirationTimeName)
void	setTasksName(String tasksName)
void	setTasksRetryInterval(long tasksRetryInterval)
void	setTasksRetryIntervalName(String tasksRetryIntervalName)
void	setTerminationTopicName(String terminationTopicName)

Methods inherited from class org.redisson.remote.BaseRemoteService

encode, get, get, get, get, getAckName, getAckName, getMap, getMethodSignature, getRequestQueueName, getResponseQueueName, getTimeout, scheduleCheck

Methods inherited from class java.lang.Object

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

Field Detail

terminationTopicName

protected String terminationTopicName

tasksCounterName

protected String tasksCounterName

statusName

protected String statusName

tasksName

protected String tasksName

schedulerQueueName

protected String schedulerQueueName

schedulerChannelName

protected String schedulerChannelName

tasksRetryIntervalName

protected String tasksRetryIntervalName

tasksExpirationTimeName

protected String tasksExpirationTimeName

tasksRetryInterval

protected long tasksRetryInterval

Constructor Detail

TasksService

public TasksService(Codec codec,
                    String name,
                    CommandAsyncExecutor commandExecutor,
                    String executorId,
                    ConcurrentMap<String,ResponseEntry> responses)

Method Detail

setTasksExpirationTimeName

public void setTasksExpirationTimeName(String tasksExpirationTimeName)

setTasksRetryIntervalName

public void setTasksRetryIntervalName(String tasksRetryIntervalName)

setTasksRetryInterval

public void setTasksRetryInterval(long tasksRetryInterval)

setTerminationTopicName

public void setTerminationTopicName(String terminationTopicName)

setStatusName

public void setStatusName(String statusName)

setTasksCounterName

public void setTasksCounterName(String tasksCounterName)

setTasksName

public void setTasksName(String tasksName)

setSchedulerChannelName

public void setSchedulerChannelName(String schedulerChannelName)

setSchedulerQueueName

public void setSchedulerQueueName(String scheduledQueueName)

addAsync

protected final RFuture<Boolean> addAsync(String requestQueueName,
                                          RemoteServiceRequest request,
                                          RemotePromise<Object> result)

Specified by:

addAsync in class BaseRemoteService

getAddCommandExecutor

protected CommandAsyncExecutor getAddCommandExecutor()

addAsync

protected RFuture<Boolean> addAsync(String requestQueueName,
                                    RemoteServiceRequest request)

removeAsync

protected RFuture<Boolean> removeAsync(String requestQueueName,
                                       RequestId taskId)

Specified by:

removeAsync in class BaseRemoteService

generateRequestId

protected RequestId generateRequestId()

Overrides:

generateRequestId in class BaseRemoteService

cancelExecutionAsync

public RFuture<Boolean> cancelExecutionAsync(RequestId requestId)

hasTaskAsync

public RFuture<Boolean> hasTaskAsync(String taskId)