Renamed ExecRuntimeImpl to InternalExecRuntime (no functional changes)
This commit is contained in:
parent
47a0eb8b65
commit
26bb4b6b9c
|
@ -52,7 +52,7 @@ import org.apache.hc.core5.util.TimeValue;
|
|||
import org.apache.hc.core5.util.Timeout;
|
||||
import org.apache.logging.log4j.Logger;
|
||||
|
||||
class ExecRuntimeImpl implements ExecRuntime, Cancellable {
|
||||
class InternalExecRuntime implements ExecRuntime, Cancellable {
|
||||
|
||||
private final Logger log;
|
||||
|
||||
|
@ -65,7 +65,7 @@ class ExecRuntimeImpl implements ExecRuntime, Cancellable {
|
|||
private volatile Object state;
|
||||
private volatile TimeValue validDuration;
|
||||
|
||||
ExecRuntimeImpl(
|
||||
InternalExecRuntime(
|
||||
final Logger log,
|
||||
final HttpClientConnectionManager manager,
|
||||
final HttpRequestExecutor requestExecutor,
|
|
@ -159,7 +159,7 @@ class InternalHttpClient extends CloseableHttpClient implements Configurable {
|
|||
setupContext(localcontext);
|
||||
final HttpRoute route = determineRoute(target, request, localcontext);
|
||||
final String exchangeId = String.format("ex-%08X", ExecSupport.getNextExecNumber());
|
||||
final ExecRuntime execRuntime = new ExecRuntimeImpl(log, connManager, requestExecutor,
|
||||
final ExecRuntime execRuntime = new InternalExecRuntime(log, connManager, requestExecutor,
|
||||
request instanceof CancellableAware ? (CancellableAware) request : null);
|
||||
final ExecChain.Scope scope = new ExecChain.Scope(exchangeId, route, request, execRuntime, localcontext);
|
||||
final ClassicHttpResponse response = this.execChain.execute(ClassicRequestCopier.INSTANCE.copy(request), scope);
|
||||
|
|
|
@ -121,7 +121,7 @@ public class MinimalHttpClient extends CloseableHttpClient {
|
|||
}
|
||||
|
||||
final HttpRoute route = new HttpRoute(RoutingSupport.normalize(target, schemePortResolver));
|
||||
final ExecRuntime execRuntime = new ExecRuntimeImpl(log, connManager, requestExecutor,
|
||||
final ExecRuntime execRuntime = new InternalExecRuntime(log, connManager, requestExecutor,
|
||||
request instanceof CancellableAware ? (CancellableAware) request : null);
|
||||
try {
|
||||
if (!execRuntime.isConnectionAcquired()) {
|
||||
|
|
|
@ -53,7 +53,7 @@ import org.mockito.Mockito;
|
|||
import org.mockito.MockitoAnnotations;
|
||||
|
||||
@SuppressWarnings({"static-access"}) // test code
|
||||
public class TestExecRuntimeImpl {
|
||||
public class TestInternalExecRuntime {
|
||||
|
||||
@Mock
|
||||
private Logger log;
|
||||
|
@ -69,13 +69,13 @@ public class TestExecRuntimeImpl {
|
|||
private ConnectionEndpoint connectionEndpoint;
|
||||
|
||||
private HttpRoute route;
|
||||
private ExecRuntimeImpl execRuntime;
|
||||
private InternalExecRuntime execRuntime;
|
||||
|
||||
@Before
|
||||
public void setup() {
|
||||
MockitoAnnotations.initMocks(this);
|
||||
route = new HttpRoute(new HttpHost("host", 80));
|
||||
execRuntime = new ExecRuntimeImpl(log, mgr, requestExecutor, cancellableAware);
|
||||
execRuntime = new InternalExecRuntime(log, mgr, requestExecutor, cancellableAware);
|
||||
}
|
||||
|
||||
@Test
|
Loading…
Reference in New Issue