Package org.redisson.executor

Class RedissonExecutorRemoteService

java.lang.Object

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, String name, CommandAsyncExecutor commandExecutor, String executorId, ConcurrentMap<String,ResponseEntry> responses)

Method Summary

Modifier and Type	Method	Description
protected RFuture<RemoteServiceRequest>	getTask(String requestId, RMap<String,RemoteServiceRequest> tasks)
protected <T> void	invokeMethod(RemoteServiceRequest request, RemoteServiceMethod method, RFuture<RemoteServiceCancelRequest> cancelRequestFuture, RPromise<RRemoteServiceResponse> responsePromise)
void	setListeners(List<TaskListener> listeners)
void	setSchedulerQueueName(String schedulerQueueName)
void	setStatusName(String statusName)
void	setTasksCounterName(String tasksCounterName)
void	setTasksExpirationTimeName(String tasksExpirationTimeName)
void	setTasksRetryIntervalName(String tasksRetryIntervalName)
void	setTaskTimeout(long taskTimeout)
void	setTerminationTopicName(String 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.Object

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

Methods inherited from interface org.redisson.api.RRemoteService

get, get, get, get

Constructor Detail

RedissonExecutorRemoteService

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

Method Detail

getTask

protected RFuture<RemoteServiceRequest> getTask(String requestId,
                                                RMap<String,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(List<TaskListener> listeners)

setTaskTimeout

public void setTaskTimeout(long taskTimeout)

setSchedulerQueueName

public void setSchedulerQueueName(String schedulerQueueName)

setTasksExpirationTimeName

public void setTasksExpirationTimeName(String tasksExpirationTimeName)

setTasksCounterName

public void setTasksCounterName(String tasksCounterName)

setStatusName

public void setStatusName(String statusName)

setTasksRetryIntervalName

public void setTasksRetryIntervalName(String tasksRetryIntervalName)

setTerminationTopicName

public void setTerminationTopicName(String terminationTopicName)