Package org.redisson.remote

Class AsyncRemoteProxy

java.lang.Object

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 String	cancelRequestMapName

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class org.redisson.remote.BaseRemoteProxy

getRequestQueueName, pollResponse, tryPollAckAgainAsync

Methods inherited from class java.lang.Object

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

Field Detail

cancelRequestMapName

protected final String cancelRequestMapName

Constructor Detail

AsyncRemoteProxy

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

Method Detail

permittedClasses

protected List<Class<?>> permittedClasses()

create

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

convertResult

protected Object convertResult(RemotePromise<Object> result,
                               Class<?> returnType)

awaitResultAsync

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