public class org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet extends org.apache.activemq.transport.http.HttpTunnelServlet
{
private static final long serialVersionUID;
protected org.apache.activemq.broker.BrokerService broker;
protected org.apache.activemq.transport.http.HttpTransportServer transportConnector;
public void <init>()
{
org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet v;
v := @this: org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet;
specialinvoke v.<org.apache.activemq.transport.http.HttpTunnelServlet: void <init>()>();
return;
}
public synchronized void init() throws javax.servlet.ServletException
{
javax.servlet.ServletException v;
org.apache.activemq.transport.http.HttpTransportFactory v;
org.apache.activemq.transport.TransportAcceptListener v;
java.lang.String v, v, v, v;
java.net.URI v;
org.apache.activemq.broker.BrokerService v, v, v, v;
org.apache.activemq.transport.TransportServer v;
java.lang.Exception v;
org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet v;
org.apache.activemq.transport.http.HttpTransportServer v, v;
javax.servlet.ServletContext v, v;
v := @this: org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet;
label:
v = v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.broker.BrokerService broker>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.broker.BrokerService createBroker()>();
v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.broker.BrokerService broker> = v;
v = virtualinvoke v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: java.lang.String getConnectorURL()>();
v = new org.apache.activemq.transport.http.HttpTransportFactory;
specialinvoke v.<org.apache.activemq.transport.http.HttpTransportFactory: void <init>()>();
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.http.HttpTransportFactory: org.apache.activemq.transport.TransportServer doBind(java.net.URI)>(v);
v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.transport.http.HttpTransportServer transportConnector> = v;
v = v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.broker.BrokerService broker>;
v = v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.transport.http.HttpTransportServer transportConnector>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector addConnector(org.apache.activemq.transport.TransportServer)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: javax.servlet.ServletContext getServletContext()>();
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.String getInitParameter(java.lang.String)>("org.apache.activemq.brokerURL");
if v == null goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Listening for internal communication on: \u0001");
virtualinvoke v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: void log(java.lang.String)>(v);
label:
v = v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.broker.BrokerService broker>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = new javax.servlet.ServletException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Exception)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to start embedded broker: \u0001");
specialinvoke v.<javax.servlet.ServletException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: org.apache.activemq.transport.http.HttpTransportServer transportConnector>;
v = virtualinvoke v.<org.apache.activemq.transport.http.HttpTransportServer: org.apache.activemq.transport.TransportAcceptListener getAcceptListener()>();
v = virtualinvoke v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: javax.servlet.ServletContext getServletContext()>();
interfaceinvoke v.<javax.servlet.ServletContext: void setAttribute(java.lang.String,java.lang.Object)>("transportChannelListener", v);
specialinvoke v.<org.apache.activemq.transport.http.HttpTunnelServlet: void init()>();
return;
catch java.lang.Exception from label to label with label;
}
protected org.apache.activemq.broker.BrokerService createBroker() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet v;
v := @this: org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet;
v = new org.apache.activemq.broker.BrokerService;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void <init>()>();
return v;
}
protected java.lang.String getConnectorURL()
{
javax.servlet.ServletContext v;
java.lang.String v, v;
org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet v;
v := @this: org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet;
v = virtualinvoke v.<org.apache.activemq.transport.http.HttpEmbeddedTunnelServlet: javax.servlet.ServletContext getServletContext()>();
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.String getServletContextName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("http://localhost/\u0001");
return v;
}
}