Class DistributedRPCInvocations.AsyncProcessor<I extends DistributedRPCInvocations.AsyncIface>

java.lang.Object
org.apache.storm.thrift.TBaseAsyncProcessor<I>
org.apache.storm.generated.DistributedRPCInvocations.AsyncProcessor<I>
All Implemented Interfaces:
org.apache.storm.thrift.TAsyncProcessor, org.apache.storm.thrift.TProcessor
Enclosing class:
DistributedRPCInvocations

public static class DistributedRPCInvocations.AsyncProcessor<I extends DistributedRPCInvocations.AsyncIface> extends org.apache.storm.thrift.TBaseAsyncProcessor<I>
  • Constructor Details

    • AsyncProcessor

      public AsyncProcessor(I iface)
    • AsyncProcessor

      protected AsyncProcessor(I iface, Map<String,org.apache.storm.thrift.AsyncProcessFunction<I,? extends org.apache.storm.thrift.TBase,?>> processMap)