public class org.apache.activemq.transport.https.HttpsClientTransport extends org.apache.activemq.transport.http.HttpClientTransport
{
private final javax.net.ssl.SSLSocketFactory sslSocketFactory;
private boolean verifyHostName;
public void <init>(org.apache.activemq.transport.util.TextWireFormat, java.net.URI)
{
java.lang.IllegalStateException v;
org.apache.activemq.transport.util.TextWireFormat v;
java.io.IOException v;
java.net.URI v;
javax.net.ssl.SSLSocketFactory v;
org.apache.activemq.transport.https.HttpsClientTransport v;
v := @this: org.apache.activemq.transport.https.HttpsClientTransport;
v := @parameter: org.apache.activemq.transport.util.TextWireFormat;
v := @parameter: java.net.URI;
specialinvoke v.<org.apache.activemq.transport.http.HttpClientTransport: void <init>(org.apache.activemq.transport.util.TextWireFormat,java.net.URI)>(v, v);
v.<org.apache.activemq.transport.https.HttpsClientTransport: boolean verifyHostName> = 1;
label:
v = virtualinvoke v.<org.apache.activemq.transport.https.HttpsClientTransport: javax.net.ssl.SSLSocketFactory createSocketFactory()>();
v.<org.apache.activemq.transport.https.HttpsClientTransport: javax.net.ssl.SSLSocketFactory sslSocketFactory> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("Error trying to configure TLS", v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
protected org.apache.http.conn.HttpClientConnectionManager createClientConnectionManager()
{
org.apache.http.impl.conn.PoolingHttpClientConnectionManager v;
org.apache.http.config.Registry v;
org.apache.activemq.transport.https.HttpsClientTransport v;
v := @this: org.apache.activemq.transport.https.HttpsClientTransport;
v = new org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
v = specialinvoke v.<org.apache.activemq.transport.https.HttpsClientTransport: org.apache.http.config.Registry createRegistry()>();
specialinvoke v.<org.apache.http.impl.conn.PoolingHttpClientConnectionManager: void <init>(org.apache.http.config.Registry)>(v);
return v;
}
private org.apache.http.config.Registry createRegistry()
{
java.lang.IllegalStateException v;
org.apache.http.config.RegistryBuilder v;
java.lang.Exception v;
javax.net.ssl.SSLSocketFactory v;
org.apache.http.config.Registry v;
org.apache.http.conn.socket.PlainConnectionSocketFactory v;
org.apache.http.conn.ssl.DefaultHostnameVerifier v;
java.lang.Object v;
org.apache.http.conn.ssl.NoopHostnameVerifier v;
org.apache.http.conn.ssl.SSLConnectionSocketFactory v;
boolean v;
org.apache.activemq.transport.https.HttpsClientTransport v;
v := @this: org.apache.activemq.transport.https.HttpsClientTransport;
v = staticinvoke <org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder create()>();
label:
v = v.<org.apache.activemq.transport.https.HttpsClientTransport: boolean verifyHostName>;
if v == 0 goto label;
v = new org.apache.http.conn.ssl.DefaultHostnameVerifier;
v = v;
specialinvoke v.<org.apache.http.conn.ssl.DefaultHostnameVerifier: void <init>()>();
goto label;
label:
v = new org.apache.http.conn.ssl.NoopHostnameVerifier;
v = v;
specialinvoke v.<org.apache.http.conn.ssl.NoopHostnameVerifier: void <init>()>();
label:
v = new org.apache.http.conn.ssl.SSLConnectionSocketFactory;
v = v.<org.apache.activemq.transport.https.HttpsClientTransport: javax.net.ssl.SSLSocketFactory sslSocketFactory>;
specialinvoke v.<org.apache.http.conn.ssl.SSLConnectionSocketFactory: void <init>(javax.net.ssl.SSLSocketFactory,javax.net.ssl.HostnameVerifier)>(v, v);
virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>("https", v);
v = <org.apache.http.conn.socket.PlainConnectionSocketFactory: org.apache.http.conn.socket.PlainConnectionSocketFactory INSTANCE>;
virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.RegistryBuilder register(java.lang.String,java.lang.Object)>("http", v);
v = virtualinvoke v.<org.apache.http.config.RegistryBuilder: org.apache.http.config.Registry build()>();
label:
return v;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("Failure trying to create scheme registry", v);
throw v;
catch java.lang.Exception from label to label with label;
}
protected javax.net.ssl.SSLSocketFactory createSocketFactory() throws java.io.IOException
{
javax.net.ssl.SSLContext v;
java.io.IOException v;
java.lang.Exception v;
javax.net.ssl.SSLSocketFactory v;
javax.net.SocketFactory v;
org.apache.activemq.broker.SslContext v, v;
org.apache.activemq.transport.https.HttpsClientTransport v;
v := @this: org.apache.activemq.transport.https.HttpsClientTransport;
v = staticinvoke <org.apache.activemq.broker.SslContext: org.apache.activemq.broker.SslContext getCurrentSslContext()>();
if v == null goto label;
v = staticinvoke <org.apache.activemq.broker.SslContext: org.apache.activemq.broker.SslContext getCurrentSslContext()>();
label:
v = virtualinvoke v.<org.apache.activemq.broker.SslContext: javax.net.ssl.SSLContext getSSLContext()>();
v = virtualinvoke v.<javax.net.ssl.SSLContext: javax.net.ssl.SSLSocketFactory getSocketFactory()>();
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Exception)>(v);
throw v;
label:
v = staticinvoke <javax.net.ssl.SSLSocketFactory: javax.net.SocketFactory getDefault()>();
return v;
catch java.lang.Exception from label to label with label;
}
protected java.lang.String getSystemPropertyPrefix()
{
org.apache.activemq.transport.https.HttpsClientTransport v;
v := @this: org.apache.activemq.transport.https.HttpsClientTransport;
return "https.";
}
public java.lang.Boolean getVerifyHostName()
{
java.lang.Boolean v;
boolean v;
org.apache.activemq.transport.https.HttpsClientTransport v;
v := @this: org.apache.activemq.transport.https.HttpsClientTransport;
v = v.<org.apache.activemq.transport.https.HttpsClientTransport: boolean verifyHostName>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
}
public void setVerifyHostName(java.lang.Boolean)
{
java.lang.Boolean v;
boolean v;
org.apache.activemq.transport.https.HttpsClientTransport v;
v := @this: org.apache.activemq.transport.https.HttpsClientTransport;
v := @parameter: java.lang.Boolean;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v.<org.apache.activemq.transport.https.HttpsClientTransport: boolean verifyHostName> = v;
return;
}
}