Package org.apache.thrift
Class AsyncProcessFunction<I,T,R>
- java.lang.Object
-
- org.apache.thrift.AsyncProcessFunction<I,T,R>
-
public abstract class AsyncProcessFunction<I,T,R> extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description AsyncProcessFunction(java.lang.String methodName)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods 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)
-
-
-
Method Detail
-
isOneway
protected abstract boolean isOneway()
-
start
public abstract void start(I iface, T args, AsyncMethodCallback<R> resultHandler) throws TException
- Throws:
TException
-
getEmptyArgsInstance
public abstract T getEmptyArgsInstance()
-
getResultHandler
public abstract AsyncMethodCallback getResultHandler(AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid)
-
getMethodName
public java.lang.String getMethodName()
-
sendResponse
public void sendResponse(AbstractNonblockingServer.AsyncFrameBuffer fb, TBase result, byte type, int seqid) throws TException
- Throws:
TException
-
-