Package org.redisson.remote

Class ReactiveRemoteProxy

java.lang.Object

org.redisson.remote.BaseRemoteProxy

org.redisson.remote.AsyncRemoteProxy

org.redisson.remote.ReactiveRemoteProxy

public class ReactiveRemoteProxy
extends AsyncRemoteProxy

Author:

Nikita Koksharov

Field Summary

Fields inherited from class org.redisson.remote.AsyncRemoteProxy

cancelRequestMapName

Constructor Summary

Constructors

Constructor	Description
ReactiveRemoteProxy(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 Object	convertResult(RemotePromise<Object> result, Class<?> returnType)
protected List<Class<?>>	permittedClasses()

Methods inherited from class org.redisson.remote.AsyncRemoteProxy

awaitResultAsync, create

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

Constructor Detail

ReactiveRemoteProxy

public ReactiveRemoteProxy(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()

Overrides:

permittedClasses in class AsyncRemoteProxy

convertResult

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

Overrides:

convertResult in class AsyncRemoteProxy