public class TBaseAsyncProcessor<I> extends java.lang.Object implements TProcessor
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
LOGGER |
Constructor and Description |
---|
TBaseAsyncProcessor(I iface,
java.util.Map<java.lang.String,AsyncProcessFunction<I,? extends TBase,?>> processMap) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,AsyncProcessFunction<I,? extends TBase,?>> |
getProcessMapView() |
boolean |
process(AbstractNonblockingServer.AsyncFrameBuffer fb) |
boolean |
process(TProtocol in,
TProtocol out) |
public TBaseAsyncProcessor(I iface, java.util.Map<java.lang.String,AsyncProcessFunction<I,? extends TBase,?>> processMap)
public java.util.Map<java.lang.String,AsyncProcessFunction<I,? extends TBase,?>> getProcessMapView()
public boolean process(AbstractNonblockingServer.AsyncFrameBuffer fb) throws TException
TException
public boolean process(TProtocol in, TProtocol out) throws TException
process
in interface TProcessor
TException