Package org.redisson.executor

Class RedissonExecutorRemoteService

org.redisson.remote.BaseRemoteService

org.redisson.RedissonRemoteService

org.redisson.executor.RedissonExecutorRemoteService

All Implemented Interfaces:

RRemoteService

public class RedissonExecutorRemoteService
extends RedissonRemoteService

Author:

Nikita Koksharov

Nested Class Summary

Nested classes/interfaces inherited from class org.redisson.RedissonRemoteService

RedissonRemoteService.Entry

Field Summary

Fields inherited from class org.redisson.remote.BaseRemoteService

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected RFuture<RemoteServiceRequest>	requestId, ,RemoteServiceRequest> tasks)
protected <T> void	invokeMethod(RemoteServiceRequest request, RemoteServiceMethod method, RFuture<RemoteServiceCancelRequest> cancelRequestFuture, RPromise<RRemoteServiceResponse> responsePromise)
void	<TaskListener> listeners)
void	schedulerQueueName)
void	statusName)
void	tasksCounterName)
void	tasksExpirationTimeName)
void	tasksRetryIntervalName)
void	setTaskTimeout(long taskTimeout)
void	terminationTopicName)

Methods inherited from class org.redisson.RedissonRemoteService

addAsync, deregister, getFreeWorkers, getPendingInvocations, getPendingInvocationsAsync, getRequestTasksMapName, register, register, register, removeAsync, tryExecute, tryExecute, tryExecuteAsync, tryExecuteAsync, tryExecuteAsync

Methods inherited from class org.redisson.remote.BaseRemoteService

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

Methods inherited from class java.lang.

, , , , , , , , , ,

Methods inherited from interface org.redisson.api.RRemoteService

get, get, get, get

Constructor Detail

RedissonExecutorRemoteService

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

Method Detail

getTask

protected  requestId,
                                                ,RemoteServiceRequest> tasks)

Overrides:

getTask in class RedissonRemoteService

invokeMethod

protected <T> void invokeMethod(RemoteServiceRequest request,
                                RemoteServiceMethod method,
                                RFuture<RemoteServiceCancelRequest> cancelRequestFuture,
                                RPromise<RRemoteServiceResponse> responsePromise)

Overrides:

invokeMethod in class RedissonRemoteService

setListeners

public void setListeners(<TaskListener> listeners)

setTaskTimeout

public void setTaskTimeout(long taskTimeout)

setSchedulerQueueName

public void setSchedulerQueueName( schedulerQueueName)

setTasksExpirationTimeName

public void setTasksExpirationTimeName( tasksExpirationTimeName)

setTasksCounterName

public void setTasksCounterName( tasksCounterName)

setStatusName

public void setStatusName( statusName)

setTasksRetryIntervalName

public void setTasksRetryIntervalName( tasksRetryIntervalName)

setTerminationTopicName

public void setTerminationTopicName( terminationTopicName)