public class org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap extends java.lang.Object
{
private org.apache.hc.core.reactor.IOReactorConfig ioReactorConfig;
private org.apache.hc.core.http.config.Http1Config http1Config;
private org.apache.hc.core.http.config.CharCodingConfig charCodingConfig;
private org.apache.hc.core.http.protocol.HttpProcessor httpProcessor;
private org.apache.hc.core.http.ConnectionReuseStrategy connStrategy;
private int defaultMaxPerRoute;
private int maxTotal;
private org.apache.hc.core.util.Timeout timeToLive;
private org.apache.hc.core.pool.PoolReusePolicy poolReusePolicy;
private org.apache.hc.core.pool.PoolConcurrencyPolicy poolConcurrencyPolicy;
private org.apache.hc.core.http.nio.ssl.TlsStrategy tlsStrategy;
private org.apache.hc.core.util.Timeout handshakeTimeout;
private org.apache.hc.core.function.Decorator ioSessionDecorator;
private org.apache.hc.core.function.Callback exceptionCallback;
private org.apache.hc.core.reactor.IOSessionListener sessionListener;
private org.apache.hc.core.http.impl.Http1StreamListener streamListener;
private org.apache.hc.core.pool.ConnPoolListener connPoolListener;
private void <init>()
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap bootstrap()
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
v = new org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
specialinvoke v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: void <init>()>();
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setIOReactorConfig(org.apache.hc.core.reactor.IOReactorConfig)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.reactor.IOReactorConfig v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.reactor.IOReactorConfig;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.reactor.IOReactorConfig ioReactorConfig> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setHttp1Config(org.apache.hc.core.http.config.Http1Config)
{
org.apache.hc.core.http.config.Http1Config v;
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.http.config.Http1Config;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.config.Http1Config http1Config> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setCharCodingConfig(org.apache.hc.core.http.config.CharCodingConfig)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.http.config.CharCodingConfig v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.http.config.CharCodingConfig;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setHttpProcessor(org.apache.hc.core.http.protocol.HttpProcessor)
{
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.http.protocol.HttpProcessor;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setConnectionReuseStrategy(org.apache.hc.core.http.ConnectionReuseStrategy)
{
org.apache.hc.core.http.ConnectionReuseStrategy v;
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.http.ConnectionReuseStrategy;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.ConnectionReuseStrategy connStrategy> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setDefaultMaxPerRoute(int)
{
int v;
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: int;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int defaultMaxPerRoute> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setMaxTotal(int)
{
int v;
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: int;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int maxTotal> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setTimeToLive(org.apache.hc.core.util.Timeout)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.util.Timeout v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.util.Timeout;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.util.Timeout timeToLive> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setPoolReusePolicy(org.apache.hc.core.pool.PoolReusePolicy)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.pool.PoolReusePolicy v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.pool.PoolReusePolicy;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.PoolReusePolicy poolReusePolicy> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setPoolConcurrencyPolicy(org.apache.hc.core.pool.PoolConcurrencyPolicy)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.pool.PoolConcurrencyPolicy;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.PoolConcurrencyPolicy poolConcurrencyPolicy> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setTlsStrategy(org.apache.hc.core.http.nio.ssl.TlsStrategy)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.http.nio.ssl.TlsStrategy v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.http.nio.ssl.TlsStrategy;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.nio.ssl.TlsStrategy tlsStrategy> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setTlsHandshakeTimeout(org.apache.hc.core.util.Timeout)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.util.Timeout v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.util.Timeout;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.util.Timeout handshakeTimeout> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setIOSessionDecorator(org.apache.hc.core.function.Decorator)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.function.Decorator v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.function.Decorator;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.function.Decorator ioSessionDecorator> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setExceptionCallback(org.apache.hc.core.function.Callback)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.function.Callback v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.function.Callback;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.function.Callback exceptionCallback> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setIOSessionListener(org.apache.hc.core.reactor.IOSessionListener)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.reactor.IOSessionListener v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.reactor.IOSessionListener;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.reactor.IOSessionListener sessionListener> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setStreamListener(org.apache.hc.core.http.impl.Http1StreamListener)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.http.impl.Http1StreamListener v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.http.impl.Http1StreamListener;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.impl.Http1StreamListener streamListener> = v;
return v;
}
public final org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap setConnPoolListener(org.apache.hc.core.pool.ConnPoolListener)
{
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.pool.ConnPoolListener v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v := @parameter: org.apache.hc.core.pool.ConnPoolListener;
v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.ConnPoolListener connPoolListener> = v;
return v;
}
public org.apache.hc.core.http.impl.bootstrap.HttpAsyncRequester create()
{
org.apache.hc.core.http.nio.ssl.BasicClientTlsStrategy v;
org.apache.hc.core.reactor.IOReactorConfig v;
org.apache.hc.core.http.config.CharCodingConfig v, v;
org.apache.hc.core.http.impl.nio.ClientHttp1IOEventHandlerFactory v;
org.apache.hc.core.pool.ManagedConnPool v;
org.apache.hc.core.http.protocol.HttpProcessor v, v;
int[] v;
org.apache.hc.core.http.config.Http1Config v, v;
org.apache.hc.core.function.Decorator v;
org.apache.hc.core.function.Callback v;
org.apache.hc.core.http.ConnectionReuseStrategy v;
org.apache.hc.core.util.Timeout v, v, v;
org.apache.hc.core.pool.ConnPoolListener v, v;
org.apache.hc.core.http.nio.ssl.TlsStrategy v, v;
org.apache.hc.core.pool.DefaultDisposalCallback v, v;
org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap v;
org.apache.hc.core.reactor.IOSessionListener v;
int v, v, v, v, v, v, v, v;
org.apache.hc.core.http.impl.Http1StreamListener v;
org.apache.hc.core.pool.PoolReusePolicy v, v;
org.apache.hc.core.pool.StrictConnPool v;
org.apache.hc.core.pool.PoolConcurrencyPolicy v, v;
org.apache.hc.core.pool.LaxConnPool v;
org.apache.hc.core.http.impl.bootstrap.HttpAsyncRequester v;
org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap;
v = <org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap$1: int[] $SwitchMap$org$apache$hc$core5$pool$PoolConcurrencyPolicy>;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.PoolConcurrencyPolicy poolConcurrencyPolicy>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.PoolConcurrencyPolicy poolConcurrencyPolicy>;
goto label;
label:
v = <org.apache.hc.core.pool.PoolConcurrencyPolicy: org.apache.hc.core.pool.PoolConcurrencyPolicy STRICT>;
label:
v = virtualinvoke v.<org.apache.hc.core.pool.PoolConcurrencyPolicy: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = new org.apache.hc.core.pool.LaxConnPool;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int defaultMaxPerRoute>;
if v <= 0 goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int defaultMaxPerRoute>;
goto label;
label:
v = 20;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.util.Timeout timeToLive>;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.PoolReusePolicy poolReusePolicy>;
v = new org.apache.hc.core.pool.DefaultDisposalCallback;
specialinvoke v.<org.apache.hc.core.pool.DefaultDisposalCallback: void <init>()>();
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.ConnPoolListener connPoolListener>;
specialinvoke v.<org.apache.hc.core.pool.LaxConnPool: void <init>(int,org.apache.hc.core.util.TimeValue,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.pool.DisposalCallback,org.apache.hc.core.pool.ConnPoolListener)>(v, v, v, v, v);
v = v;
goto label;
label:
v = new org.apache.hc.core.pool.StrictConnPool;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int defaultMaxPerRoute>;
if v <= 0 goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int defaultMaxPerRoute>;
goto label;
label:
v = 20;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int maxTotal>;
if v <= 0 goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: int maxTotal>;
goto label;
label:
v = 50;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.util.Timeout timeToLive>;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.PoolReusePolicy poolReusePolicy>;
v = new org.apache.hc.core.pool.DefaultDisposalCallback;
specialinvoke v.<org.apache.hc.core.pool.DefaultDisposalCallback: void <init>()>();
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.pool.ConnPoolListener connPoolListener>;
specialinvoke v.<org.apache.hc.core.pool.StrictConnPool: void <init>(int,int,org.apache.hc.core.util.TimeValue,org.apache.hc.core.pool.PoolReusePolicy,org.apache.hc.core.pool.DisposalCallback,org.apache.hc.core.pool.ConnPoolListener)>(v, v, v, v, v, v);
v = v;
label:
v = new org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
goto label;
label:
v = staticinvoke <org.apache.hc.core.http.impl.HttpProcessors: org.apache.hc.core.http.protocol.HttpProcessor client()>();
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.config.Http1Config http1Config>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.config.Http1Config http1Config>;
goto label;
label:
v = <org.apache.hc.core.http.config.Http1Config: org.apache.hc.core.http.config.Http1Config DEFAULT>;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig>;
goto label;
label:
v = <org.apache.hc.core.http.config.CharCodingConfig: org.apache.hc.core.http.config.CharCodingConfig DEFAULT>;
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.ConnectionReuseStrategy connStrategy>;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.impl.Http1StreamListener streamListener>;
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory: void <init>(org.apache.hc.core.http.protocol.HttpProcessor,org.apache.hc.core.http.config.Http1Config,org.apache.hc.core.http.config.CharCodingConfig,org.apache.hc.core.http.ConnectionReuseStrategy,org.apache.hc.core.http.nio.NHttpMessageParserFactory,org.apache.hc.core.http.nio.NHttpMessageWriterFactory,org.apache.hc.core.http.impl.Http1StreamListener)>(v, v, v, v, null, null, v);
v = new org.apache.hc.core.http.impl.nio.ClientHttp1IOEventHandlerFactory;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.nio.ssl.TlsStrategy tlsStrategy>;
if v == null goto label;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.http.nio.ssl.TlsStrategy tlsStrategy>;
goto label;
label:
v = new org.apache.hc.core.http.nio.ssl.BasicClientTlsStrategy;
v = v;
specialinvoke v.<org.apache.hc.core.http.nio.ssl.BasicClientTlsStrategy: void <init>()>();
label:
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.util.Timeout handshakeTimeout>;
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientHttp1IOEventHandlerFactory: void <init>(org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory,org.apache.hc.core.http.nio.ssl.TlsStrategy,org.apache.hc.core.util.Timeout)>(v, v, v);
v = new org.apache.hc.core.http.impl.bootstrap.HttpAsyncRequester;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.reactor.IOReactorConfig ioReactorConfig>;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.function.Decorator ioSessionDecorator>;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.function.Callback exceptionCallback>;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncRequesterBootstrap: org.apache.hc.core.reactor.IOSessionListener sessionListener>;
specialinvoke v.<org.apache.hc.core.http.impl.bootstrap.HttpAsyncRequester: void <init>(org.apache.hc.core.reactor.IOReactorConfig,org.apache.hc.core.reactor.IOEventHandlerFactory,org.apache.hc.core.function.Decorator,org.apache.hc.core.function.Callback,org.apache.hc.core.reactor.IOSessionListener,org.apache.hc.core.pool.ManagedConnPool)>(v, v, v, v, v, v);
return v;
}
}