public class InFlightRequest extends Object
InFlightRequest(int timeoutSec, int concurrentNum)
void
put(ResponseFuture rf)
ResponseFuture
remove(String action, Long id)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public InFlightRequest(int timeoutSec, int concurrentNum)
public void put(ResponseFuture rf) throws InterruptedException, TimeoutException
InterruptedException
TimeoutException
public ResponseFuture remove(String action, Long id)
Copyright © 2022. All rights reserved.