Package org.redisson

Class RedissonRemoteService

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

Method Summary

Modifier and Type	Method	Description
protected >	requestQueueName, RemoteServiceRequest request, > result)
<T> void	<T> remoteInterface)	Deregister all workers for remote service
int	<?> remoteInterface)	Returns free workers amount available for invocations
int	<?> remoteInterface)	Returns pending invocations amount for handling in free workers.
>	<?> remoteInterface)	Returns pending invocations amount for handling in free workers.
	<?> remoteInterface)
protected RFuture<RemoteServiceRequest>	requestId, ,RemoteServiceRequest> tasks)
protected <T> void	invokeMethod(RemoteServiceRequest request, RemoteServiceMethod method, RFuture<RemoteServiceCancelRequest> cancelRequestFuture, RPromise<RRemoteServiceResponse> responsePromise)
<T> void	<T> remoteInterface, T object)	Register remote service with single worker
<T> void	<T> remoteInterface, T object, int workers)	Register remote service with custom workers amount
<T> void	<T> remoteInterface, T object, int workers, executor)	Register remote service with custom workers amount and executor for running them
protected >	requestQueueName, RequestId taskId)
<T> boolean	<T> remoteInterface, T object, long timeout, timeUnit)	Tries to execute one awaiting remote request.
<T> boolean	<T> remoteInterface, T object, executorService, long timeout, timeUnit)	Tries to execute one awaiting remote request.
<T> >	<T> remoteInterface, T object)	Tries to execute one awaiting remote request.
<T> >	<T> remoteInterface, T object, long timeout, timeUnit)	Tries to execute one awaiting remote request.
<T> >	<T> remoteInterface, T object, executor, long timeout, 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.

, , , , , , , , , ,

Methods inherited from interface org.redisson.api.RRemoteService

get, get, get, get

Constructor Detail

RedissonRemoteService

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

Method Detail

getRequestTasksMapName

public  getRequestTasksMapName(<?> remoteInterface)

addAsync

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

Specified by:

addAsync in class BaseRemoteService

removeAsync

protected > removeAsync( requestQueueName,
                                       RequestId taskId)

Specified by:

removeAsync in class BaseRemoteService

register

public <T> void register(<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(<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(<?> 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 > getPendingInvocationsAsync(<?> 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(<?> 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(<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(<T> remoteInterface,
                         T object,
                         int workers,
                          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(<T> remoteInterface,
                              T object,
                              long timeout,
                               timeUnit)
                       throws 

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:

- - if the thread is interrupted

tryExecute

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

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:

- - if the thread is interrupted

tryExecuteAsync

public <T> > tryExecuteAsync(<T> remoteInterface,
                                            T object,
                                            long timeout,
                                             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> > tryExecuteAsync(<T> remoteInterface,
                                            T object,
                                             executor,
                                            long timeout,
                                             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> > tryExecuteAsync(<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  requestId,
                                                ,RemoteServiceRequest> tasks)