public abstract class AsyncProcessFunction<I,T,R>
extends java.lang.Object
Constructor and Description |
---|
AsyncProcessFunction(java.lang.String methodName) |
Modifier and Type | Method and 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