public abstract class AsyncProcessFunction<I,T,R>
extends java.lang.Object
Constructor | Description |
---|---|
AsyncProcessFunction(java.lang.String methodName) |
Modifier and Type | Method | Description |
---|---|---|
abstract T |
getEmptyArgsInstance() |
|
java.lang.String |
getMethodName() |
|
abstract AsyncMethodCallback |
getResultHandler(AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
|
protected abstract boolean |
isOneway() |
|
void |
sendResponse(AbstractNonblockingServer.AsyncFrameBuffer fb,
TBase result,
byte type,
int seqid) |
|
abstract void |
start(I iface,
T args,
AsyncMethodCallback<R> resultHandler) |
protected abstract boolean isOneway()
public abstract void start(I iface, T args, AsyncMethodCallback<R> resultHandler) throws TException
TException
public abstract T getEmptyArgsInstance()
public abstract AsyncMethodCallback getResultHandler(AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid)
public java.lang.String getMethodName()
public void sendResponse(AbstractNonblockingServer.AsyncFrameBuffer fb, TBase result, byte type, int seqid) throws TException
TException