com.alipay.remoting

接口 InvokeFuture

所有已知实现类:

DefaultInvokeFuture

public interface InvokeFuture

The future of an invocation.

方法概要

方法

限定符和类型	方法和说明
void	addTimeout(io.netty.util.Timeout timeout) Add timeout for the future.
void	cancelTimeout() Cancel the timeout.
RemotingCommand	createConnectionClosedResponse(InetSocketAddress responseHost) Create a remoting command response when connection closed
void	executeInvokeCallback() Execute the callback.
ClassLoader	getAppClassLoader()
Throwable	getCause() Get the cause of exception of the future.
InvokeCallback	getInvokeCallback() Get the application callback of the future.
InvokeContext	getInvokeContext() get invoke context
byte	getProtocolCode() Get the protocol code of command.
int	invokeId() Get the id of the invocation.
boolean	isDone() Whether the future is done.
void	putResponse(RemotingCommand response) Put the response to the future.
void	setCause(Throwable cause) Set the cause if exception caught.
void	setInvokeContext(InvokeContext invokeContext) set invoke context
void	tryAsyncExecuteInvokeCallbackAbnormally() Asynchronous execute the callback abnormally.
RemotingCommand	waitResponse() Wait response with unlimit timeout
RemotingCommand	waitResponse(long timeoutMillis) Wait response with timeout.

方法详细资料

waitResponse

RemotingCommand waitResponse(long timeoutMillis)
                             throws InterruptedException

Wait response with timeout.

参数:

timeoutMillis -

返回:

抛出:

InterruptedException

waitResponse

RemotingCommand waitResponse()
                             throws InterruptedException

Wait response with unlimit timeout

返回:

抛出:

InterruptedException

createConnectionClosedResponse

RemotingCommand createConnectionClosedResponse(InetSocketAddress responseHost)

Create a remoting command response when connection closed

参数:

responseHost -

返回:

putResponse

void putResponse(RemotingCommand response)

Put the response to the future.

参数:

response -

invokeId

int invokeId()

Get the id of the invocation.

返回:

executeInvokeCallback

void executeInvokeCallback()

Execute the callback.

tryAsyncExecuteInvokeCallbackAbnormally

void tryAsyncExecuteInvokeCallbackAbnormally()

Asynchronous execute the callback abnormally.

setCause

void setCause(Throwable cause)

Set the cause if exception caught.

参数:

cause -

getCause

Throwable getCause()

Get the cause of exception of the future.

返回:

getInvokeCallback

InvokeCallback getInvokeCallback()

Get the application callback of the future.

返回:

addTimeout

void addTimeout(io.netty.util.Timeout timeout)

Add timeout for the future.

参数:

timeout -

cancelTimeout

void cancelTimeout()

Cancel the timeout.

isDone

boolean isDone()

Whether the future is done.

返回:

getAppClassLoader

ClassLoader getAppClassLoader()

返回:

application classloader

getProtocolCode

byte getProtocolCode()

Get the protocol code of command.

返回:

setInvokeContext

void setInvokeContext(InvokeContext invokeContext)

set invoke context

参数:

invokeContext -

getInvokeContext

InvokeContext getInvokeContext()

get invoke context

返回: