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