Package org.redisson.remote

Class AsyncRemoteProxy

org.redisson.remote.BaseRemoteProxy

org.redisson.remote.AsyncRemoteProxy

Direct Known Subclasses:

ReactiveRemoteProxy, RxRemoteProxy

public class AsyncRemoteProxy
extends BaseRemoteProxy

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
protected	cancelRequestMapName

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	awaitResultAsync(RemoteInvocationOptions optionsCopy, > result, RFuture<RRemoteServiceResponse> responseFuture)
protected	> result, <?> returnType)
<T> T	<T> remoteInterface, RemoteInvocationOptions options, <?> syncInterface)
protected <<?>>	permittedClasses()

Methods inherited from class org.redisson.remote.BaseRemoteProxy

getRequestQueueName, pollResponse, tryPollAckAgainAsync

Methods inherited from class java.lang.

, , , , , , , , , ,

Field Detail

cancelRequestMapName

protected final  cancelRequestMapName

Constructor Detail

AsyncRemoteProxy

public AsyncRemoteProxy(CommandAsyncExecutor commandExecutor,
                         name,
                         responseQueueName,
                        <,ResponseEntry> responses,
                        Codec codec,
                         executorId,
                         cancelRequestMapName,
                        BaseRemoteService remoteService)

Method Detail

permittedClasses

protected <<?>> permittedClasses()

create

public <T> T create(<T> remoteInterface,
                    RemoteInvocationOptions options,
                    <?> syncInterface)

convertResult

protected  convertResult(> result,
                               <?> returnType)

awaitResultAsync

protected void awaitResultAsync(RemoteInvocationOptions optionsCopy,
                                > result,
                                RFuture<RRemoteServiceResponse> responseFuture)