Package org.redisson.executor

Class TasksService

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	schedulerChannelName
protected	schedulerQueueName
protected	statusName
protected	tasksCounterName
protected	tasksExpirationTimeName
protected	tasksName
protected long	tasksRetryInterval
protected	tasksRetryIntervalName
protected	terminationTopicName

Fields inherited from class org.redisson.remote.BaseRemoteService

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected >	requestQueueName, RemoteServiceRequest request)
protected >	requestQueueName, RemoteServiceRequest request, > result)
>	cancelExecutionAsync(RequestId requestId)
protected RequestId	generateRequestId()
protected CommandAsyncExecutor	getAddCommandExecutor()
>	taskId)
protected >	requestQueueName, RequestId taskId)
void	schedulerChannelName)
void	scheduledQueueName)
void	statusName)
void	tasksCounterName)
void	tasksExpirationTimeName)
void	tasksName)
void	setTasksRetryInterval(long tasksRetryInterval)
void	tasksRetryIntervalName)
void	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.

, , , , , , , , , ,

Field Detail

terminationTopicName

protected  terminationTopicName

tasksCounterName

protected  tasksCounterName

statusName

protected  statusName

tasksName

protected  tasksName

schedulerQueueName

protected  schedulerQueueName

schedulerChannelName

protected  schedulerChannelName

tasksRetryIntervalName

protected  tasksRetryIntervalName

tasksExpirationTimeName

protected  tasksExpirationTimeName

tasksRetryInterval

protected long tasksRetryInterval

Constructor Detail

TasksService

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

Method Detail

setTasksExpirationTimeName

public void setTasksExpirationTimeName( tasksExpirationTimeName)

setTasksRetryIntervalName

public void setTasksRetryIntervalName( tasksRetryIntervalName)

setTasksRetryInterval

public void setTasksRetryInterval(long tasksRetryInterval)

setTerminationTopicName

public void setTerminationTopicName( terminationTopicName)

setStatusName

public void setStatusName( statusName)

setTasksCounterName

public void setTasksCounterName( tasksCounterName)

setTasksName

public void setTasksName( tasksName)

setSchedulerChannelName

public void setSchedulerChannelName( schedulerChannelName)

setSchedulerQueueName

public void setSchedulerQueueName( scheduledQueueName)

addAsync

protected final > addAsync( requestQueueName,
                                          RemoteServiceRequest request,
                                          > result)

Specified by:

addAsync in class BaseRemoteService

getAddCommandExecutor

protected CommandAsyncExecutor getAddCommandExecutor()

addAsync

protected > addAsync( requestQueueName,
                                    RemoteServiceRequest request)

removeAsync

protected > removeAsync( requestQueueName,
                                       RequestId taskId)

Specified by:

removeAsync in class BaseRemoteService

generateRequestId

protected RequestId generateRequestId()

Overrides:

generateRequestId in class BaseRemoteService

cancelExecutionAsync

public > cancelExecutionAsync(RequestId requestId)

hasTaskAsync

public > hasTaskAsync( taskId)