Class DistributedRPC.AsyncProcessor<I extends DistributedRPC.AsyncIface>

  • All Implemented Interfaces:
    org.apache.storm.thrift.TAsyncProcessor, org.apache.storm.thrift.TProcessor
    Enclosing class:
    DistributedRPC

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

      • 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)