com.fr.workspace.engine.server.rpc.netty

类 AbstractMessageReceiveInitializeTask

java.lang.Object

com.fr.workspace.engine.server.rpc.netty.AbstractMessageReceiveInitializeTask

所有已实现的接口:

java.util.concurrent.Callable<java.lang.Boolean>

直接已知子类:

HashMessageReceiveInitializeTask, MessageReceiveInitializeTask, MessageReceiveInitializeTaskAdapter

public abstract class AbstractMessageReceiveInitializeTask
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Boolean>

字段概要

字段

限定符和类型	字段和说明
protected java.util.Map<java.lang.String,java.lang.Object>	handlerMap
protected long	invokeTimespan
protected static java.lang.String	METHOD_MAPPED_NAME
protected MessageRequest	request
protected MessageResponse	response
protected boolean	returnNotNull

构造器概要

构造器

构造器和说明
AbstractMessageReceiveInitializeTask(MessageRequest request, MessageResponse response, java.util.Map<java.lang.String,java.lang.Object> handlerMap)

方法概要

方法

限定符和类型	方法和说明
protected abstract void	acquire()
java.lang.Boolean	call()
MessageRequest	getRequest()
MessageResponse	getResponse()
java.lang.String	getStackTrace(java.lang.Throwable ex)
protected abstract void	injectFailInvoke(java.lang.Throwable error)
protected abstract void	injectFilterInvoke()
protected abstract void	injectInvoke()
protected abstract void	injectSuccessInvoke(long invokeTimespan)
boolean	isReturnNotNull()
protected abstract void	release()
void	setRequest(MessageRequest request)
void	setReturnNotNull(boolean returnNotNull)

从类继承的方法 java.lang.Object

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

字段详细资料

request

protected MessageRequest request

response

protected MessageResponse response

handlerMap

protected java.util.Map<java.lang.String,java.lang.Object> handlerMap

METHOD_MAPPED_NAME

protected static final java.lang.String METHOD_MAPPED_NAME

另请参阅:

常量字段值

returnNotNull

protected boolean returnNotNull

invokeTimespan

protected long invokeTimespan

构造器详细资料

AbstractMessageReceiveInitializeTask

public AbstractMessageReceiveInitializeTask(MessageRequest request,
                                    MessageResponse response,
                                    java.util.Map<java.lang.String,java.lang.Object> handlerMap)

方法详细资料

call

public java.lang.Boolean call()

指定者:

call 在接口中 java.util.concurrent.Callable<java.lang.Boolean>

getStackTrace

public java.lang.String getStackTrace(java.lang.Throwable ex)

isReturnNotNull

public boolean isReturnNotNull()

setReturnNotNull

public void setReturnNotNull(boolean returnNotNull)

getResponse

public MessageResponse getResponse()

getRequest

public MessageRequest getRequest()

setRequest

public void setRequest(MessageRequest request)

injectInvoke

protected abstract void injectInvoke()

injectSuccessInvoke

protected abstract void injectSuccessInvoke(long invokeTimespan)

injectFailInvoke

protected abstract void injectFailInvoke(java.lang.Throwable error)

injectFilterInvoke

protected abstract void injectFilterInvoke()

acquire

protected abstract void acquire()

release

protected abstract void release()