}
}
public ClientConnectionRequest requestConnection(final HttpRoute route, final Object state) {
final PoolEntryRequest poolRequest = pool.requestPoolEntry(route, state);
return new ClientConnectionRequest() {
public void abortRequest() {
poolRequest.abortRequest();
}
public ManagedClientConnection getConnection(long timeout, TimeUnit tunit) throws InterruptedException,
ConnectionPoolTimeoutException {
if (route == null) {
throw new IllegalArgumentException("Route may not be null.");
}
if (log.isDebugEnabled()) {
log.debug("Get connection: " + route + ", timeout = " + timeout);
}
BasicPoolEntry entry = poolRequest.getPoolEntry(timeout, tunit);
SoapUIBasicPooledConnAdapter connAdapter = new SoapUIBasicPooledConnAdapter(
SoapUIMultiThreadedHttpConnectionManager.this, entry);
return connAdapter;
}
};