Package org.redisson.remote

Class BaseRemoteProxy

java.lang.Object

org.redisson.remote.BaseRemoteProxy

Direct Known Subclasses:

AsyncRemoteProxy, SyncRemoteProxy

public abstract class BaseRemoteProxy
extends Object

Author:

Nikita Koksharov

Method Summary

Modifier and Type	Method	Description
String	getRequestQueueName(Class<?> remoteInterface)
protected <T extends RRemoteServiceResponse> CompletableFuture<T>	pollResponse(long timeout, RequestId requestId, boolean insertFirst)
protected CompletionStage<RemoteServiceAck>	tryPollAckAgainAsync(RemoteInvocationOptions optionsCopy, String ackName, RequestId requestId)

Methods inherited from class java.lang.Object

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

Method Detail

getRequestQueueName

public String getRequestQueueName(Class<?> remoteInterface)

tryPollAckAgainAsync

protected CompletionStage<RemoteServiceAck> tryPollAckAgainAsync(RemoteInvocationOptions optionsCopy,
                                                                 String ackName,
                                                                 RequestId requestId)

pollResponse

protected final <T extends RRemoteServiceResponse> CompletableFuture<T> pollResponse(long timeout,
                                                                                     RequestId requestId,
                                                                                     boolean insertFirst)