Package org.redisson

Class RedissonRemoteService

java.lang.Object

org.redisson.remote.BaseRemoteService

org.redisson.RedissonRemoteService

All Implemented Interfaces:

RRemoteService

Direct Known Subclasses:

RedissonExecutorRemoteService

public class RedissonRemoteService
extends BaseRemoteService
implements RRemoteService

Author:

Nikita Koksharov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RedissonRemoteService.Entry

Field Summary

Fields inherited from class org.redisson.remote.BaseRemoteService

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

Constructor Summary

Constructors

Constructor	Description
RedissonRemoteService(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, RemotePromise<Object> result)
<T> void	deregister(Class<T> remoteInterface)	Deregister all workers for remote service
int	getFreeWorkers(Class<?> remoteInterface)	Returns free workers amount available for invocations
int	getPendingInvocations(Class<?> remoteInterface)	Returns pending invocations amount for handling in free workers.
RFuture<Integer>	getPendingInvocationsAsync(Class<?> remoteInterface)	Returns pending invocations amount for handling in free workers.
String	getRequestTasksMapName(Class<?> remoteInterface)
protected RFuture<RemoteServiceRequest>	getTask(String requestId, RMap<String,RemoteServiceRequest> tasks)
protected <T> void	invokeMethod(RemoteServiceRequest request, RemoteServiceMethod method, RFuture<RemoteServiceCancelRequest> cancelRequestFuture, RPromise<RRemoteServiceResponse> responsePromise)
<T> void	register(Class<T> remoteInterface, T object)	Register remote service with single worker
<T> void	register(Class<T> remoteInterface, T object, int workers)	Register remote service with custom workers amount
<T> void	register(Class<T> remoteInterface, T object, int workers, ExecutorService executor)	Register remote service with custom workers amount and executor for running them
protected RFuture<Boolean>	removeAsync(String requestQueueName, RequestId taskId)
<T> boolean	tryExecute(Class<T> remoteInterface, T object, long timeout, TimeUnit timeUnit)	Tries to execute one awaiting remote request.
<T> boolean	tryExecute(Class<T> remoteInterface, T object, ExecutorService executorService, long timeout, TimeUnit timeUnit)	Tries to execute one awaiting remote request.
<T> RFuture<Boolean>	tryExecuteAsync(Class<T> remoteInterface, T object)	Tries to execute one awaiting remote request.
<T> RFuture<Boolean>	tryExecuteAsync(Class<T> remoteInterface, T object, long timeout, TimeUnit timeUnit)	Tries to execute one awaiting remote request.
<T> RFuture<Boolean>	tryExecuteAsync(Class<T> remoteInterface, T object, ExecutorService executor, long timeout, TimeUnit timeUnit)	Tries to execute one awaiting remote request.

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

RedissonRemoteService

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

Method Detail

getRequestTasksMapName

public String getRequestTasksMapName(Class<?> remoteInterface)

addAsync

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

Specified by:

addAsync in class BaseRemoteService

removeAsync

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

Specified by:

removeAsync in class BaseRemoteService

register

public <T> void register(Class<T> remoteInterface,
                         T object)

Description copied from interface: RRemoteService

Register remote service with single worker

Specified by:

register in interface RRemoteService

Type Parameters:

T - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

deregister

public <T> void deregister(Class<T> remoteInterface)

Description copied from interface: RRemoteService

Deregister all workers for remote service

Specified by:

deregister in interface RRemoteService

Type Parameters:

T - type of remote service

Parameters:

remoteInterface - - remote service interface

getPendingInvocations

public int getPendingInvocations(Class<?> remoteInterface)

Description copied from interface: RRemoteService

Returns pending invocations amount for handling in free workers.

Specified by:

getPendingInvocations in interface RRemoteService

Parameters:

remoteInterface - - remote service interface

Returns:

invocations amount

getPendingInvocationsAsync

public RFuture<Integer> getPendingInvocationsAsync(Class<?> remoteInterface)

Description copied from interface: RRemoteService

Returns pending invocations amount for handling in free workers.

Specified by:

getPendingInvocationsAsync in interface RRemoteService

Parameters:

remoteInterface - - remote service interface

Returns:

invocations amount

getFreeWorkers

public int getFreeWorkers(Class<?> remoteInterface)

Description copied from interface: RRemoteService

Returns free workers amount available for invocations

Specified by:

getFreeWorkers in interface RRemoteService

Parameters:

remoteInterface - - remote service interface

Returns:

workers amount

register

public <T> void register(Class<T> remoteInterface,
                         T object,
                         int workers)

Description copied from interface: RRemoteService

Register remote service with custom workers amount

Specified by:

register in interface RRemoteService

Type Parameters:

T - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

workers - - workers amount

register

public <T> void register(Class<T> remoteInterface,
                         T object,
                         int workers,
                         ExecutorService executor)

Description copied from interface: RRemoteService

Register remote service with custom workers amount and executor for running them

Specified by:

register in interface RRemoteService

Type Parameters:

T - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

workers - - workers amount

executor - - executor service used to invoke methods

tryExecute

public <T> boolean tryExecute(Class<T> remoteInterface,
                              T object,
                              long timeout,
                              TimeUnit timeUnit)
                       throws InterruptedException

Description copied from interface: RRemoteService

Tries to execute one awaiting remote request. Waits up to timeout if necessary until remote request became available.

Specified by:

tryExecute in interface RRemoteService

Type Parameters:

T - - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

timeout - - maximum wait time until remote request became available

timeUnit - - time unit

Returns:

true if method was successfully executed and false if timeout reached before execution

Throws:

InterruptedException - - if the thread is interrupted

tryExecute

public <T> boolean tryExecute(Class<T> remoteInterface,
                              T object,
                              ExecutorService executorService,
                              long timeout,
                              TimeUnit timeUnit)
                       throws InterruptedException

Description copied from interface: RRemoteService

Tries to execute one awaiting remote request. Waits up to timeout if necessary until remote request became available.

Specified by:

tryExecute in interface RRemoteService

Type Parameters:

T - - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

executorService - - executor service used to invoke methods

timeout - - maximum wait time until remote request became available

timeUnit - - time unit

Returns:

true if method was successfully executed and false if timeout reached before execution

Throws:

InterruptedException - - if the thread is interrupted

tryExecuteAsync

public <T> RFuture<Boolean> tryExecuteAsync(Class<T> remoteInterface,
                                            T object,
                                            long timeout,
                                            TimeUnit timeUnit)

Description copied from interface: RRemoteService

Tries to execute one awaiting remote request. Waits up to timeout if necessary until remote request became available.

Specified by:

tryExecuteAsync in interface RRemoteService

Type Parameters:

T - - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

timeout - - maximum wait time until remote request became available

timeUnit - - time unit

Returns:

true if method was successfully executed and false if timeout reached before execution

tryExecuteAsync

public <T> RFuture<Boolean> tryExecuteAsync(Class<T> remoteInterface,
                                            T object,
                                            ExecutorService executor,
                                            long timeout,
                                            TimeUnit timeUnit)

Description copied from interface: RRemoteService

Tries to execute one awaiting remote request. Waits up to timeout if necessary until remote request became available.

Specified by:

tryExecuteAsync in interface RRemoteService

Type Parameters:

T - - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

executor - - executor service used to invoke methods

timeout - - maximum wait time until remote request became available

timeUnit - - time unit

Returns:

true if method was successfully executed and false if timeout reached before execution

tryExecuteAsync

public <T> RFuture<Boolean> tryExecuteAsync(Class<T> remoteInterface,
                                            T object)

Description copied from interface: RRemoteService

Tries to execute one awaiting remote request.

Specified by:

tryExecuteAsync in interface RRemoteService

Type Parameters:

T - - type of remote service

Parameters:

remoteInterface - - remote service interface

object - - remote service object

Returns:

true if method was successfully executed and false if timeout reached before execution

invokeMethod

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

getTask

protected RFuture<RemoteServiceRequest> getTask(String requestId,
                                                RMap<String,RemoteServiceRequest> tasks)