Package org.redisson.remote

Class BaseRemoteService

org.redisson.remote.BaseRemoteService

Direct Known Subclasses:

RedissonRemoteService, TasksService

public abstract class BaseRemoteService
extends 

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
protected	cancelRequestMapName
protected	cancelResponseMapName
protected Codec	codec
protected CommandAsyncExecutor	commandExecutor
protected	executorId
protected	name
protected	responseQueueName

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected abstract >	requestQueueName, RemoteServiceRequest request, > result)
protected io.netty.buffer.ByteBuf	obj)
protected RequestId	generateRequestId()
<T> T	<T> remoteInterface)
<T> T	<T> remoteInterface, long executionTimeout, executionTimeUnit)
<T> T	<T> remoteInterface, long executionTimeout, executionTimeUnit, long ackTimeout, ackTimeUnit)
<T> T	<T> remoteInterface, RemoteInvocationOptions options)
protected	requestId)
protected	getAckName(RequestId requestId)
protected <K,V> RMap<K,V>	name)
protected long[]	method)
	<?> remoteInterface)
	executorId)
protected long	executionTimeoutInMillis, RemoteServiceRequest request)
protected abstract >	requestQueueName, RequestId taskId)
protected <T> void	mapName, RequestId requestId, RPromise<T> cancelRequest)

Methods inherited from class java.lang.

, , , , , , , , , ,

Field Detail

codec

protected final Codec codec

name

protected final  name

commandExecutor

protected final CommandAsyncExecutor commandExecutor

executorId

protected final  executorId

cancelRequestMapName

protected final  cancelRequestMapName

cancelResponseMapName

protected final  cancelResponseMapName

responseQueueName

protected final  responseQueueName

Constructor Detail

BaseRemoteService

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

Method Detail

getResponseQueueName

public  getResponseQueueName( executorId)

getAckName

protected  getAckName(RequestId requestId)

getAckName

protected  getAckName( requestId)

getRequestQueueName

public  getRequestQueueName(<?> remoteInterface)

encode

protected io.netty.buffer.ByteBuf encode( obj)

get

public <T> T get(<T> remoteInterface)

get

public <T> T get(<T> remoteInterface,
                 long executionTimeout,
                  executionTimeUnit)

get

public <T> T get(<T> remoteInterface,
                 long executionTimeout,
                  executionTimeUnit,
                 long ackTimeout,
                  ackTimeUnit)

get

public <T> T get(<T> remoteInterface,
                 RemoteInvocationOptions options)

getTimeout

protected long getTimeout( executionTimeoutInMillis,
                          RemoteServiceRequest request)

getMap

protected <K,V>  name)

scheduleCheck

protected <T> void scheduleCheck( mapName,
                                 RequestId requestId,
                                 RPromise<T> cancelRequest)

generateRequestId

protected RequestId generateRequestId()

addAsync

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

removeAsync

protected abstract > removeAsync( requestQueueName,
                                                RequestId taskId)

getMethodSignature

protected long[] getMethodSignature( method)