public class org.apache.activemq.transport.discovery.http.EmbeddedJettyServer extends java.lang.Object implements org.apache.activemq.Service
{
private org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent agent;
private org.eclipse.jetty.server.Server server;
private org.apache.activemq.transport.discovery.http.DiscoveryRegistryServlet camelServlet;
public void <init>()
{
org.apache.activemq.transport.discovery.http.EmbeddedJettyServer v;
org.apache.activemq.transport.discovery.http.DiscoveryRegistryServlet v;
v := @this: org.apache.activemq.transport.discovery.http.EmbeddedJettyServer;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.activemq.transport.discovery.http.DiscoveryRegistryServlet;
specialinvoke v.<org.apache.activemq.transport.discovery.http.DiscoveryRegistryServlet: void <init>()>();
v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.apache.activemq.transport.discovery.http.DiscoveryRegistryServlet camelServlet> = v;
return;
}
public void start() throws java.lang.Exception
{
org.eclipse.jetty.servlet.ServletContextHandler v;
org.eclipse.jetty.servlet.ServletHolder v;
org.apache.activemq.transport.discovery.http.EmbeddedJettyServer v;
org.apache.activemq.transport.discovery.http.DiscoveryRegistryServlet v;
int v, v;
org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent v;
java.lang.String v;
java.net.URI v;
org.eclipse.jetty.server.Server v, v, v;
v := @this: org.apache.activemq.transport.discovery.http.EmbeddedJettyServer;
v = new java.net.URI;
v = v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent agent>;
v = virtualinvoke v.<org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent: java.lang.String getRegistryURL()>();
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = 80;
v = virtualinvoke v.<java.net.URI: int getPort()>();
if v < 0 goto label;
v = virtualinvoke v.<java.net.URI: int getPort()>();
label:
v = new org.eclipse.jetty.server.Server;
specialinvoke v.<org.eclipse.jetty.server.Server: void <init>(int)>(v);
v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.eclipse.jetty.server.Server server> = v;
v = new org.eclipse.jetty.servlet.ServletContextHandler;
specialinvoke v.<org.eclipse.jetty.servlet.ServletContextHandler: void <init>(int)>(0);
virtualinvoke v.<org.eclipse.jetty.servlet.ServletContextHandler: void setContextPath(java.lang.String)>("/");
v = new org.eclipse.jetty.servlet.ServletHolder;
specialinvoke v.<org.eclipse.jetty.servlet.ServletHolder: void <init>()>();
v = v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.apache.activemq.transport.discovery.http.DiscoveryRegistryServlet camelServlet>;
virtualinvoke v.<org.eclipse.jetty.servlet.ServletHolder: void setServlet(javax.servlet.Servlet)>(v);
virtualinvoke v.<org.eclipse.jetty.servlet.ServletContextHandler: void addServlet(org.eclipse.jetty.servlet.ServletHolder,java.lang.String)>(v, "/*");
v = v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.eclipse.jetty.server.Server server>;
virtualinvoke v.<org.eclipse.jetty.server.Server: void setHandler(org.eclipse.jetty.server.Handler)>(v);
v = v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.eclipse.jetty.server.Server server>;
virtualinvoke v.<org.eclipse.jetty.server.Server: void start()>();
return;
}
public void stop() throws java.lang.Exception
{
org.apache.activemq.transport.discovery.http.EmbeddedJettyServer v;
org.eclipse.jetty.server.Server v, v;
v := @this: org.apache.activemq.transport.discovery.http.EmbeddedJettyServer;
v = v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.eclipse.jetty.server.Server server>;
if v == null goto label;
v = v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.eclipse.jetty.server.Server server>;
virtualinvoke v.<org.eclipse.jetty.server.Server: void stop()>();
v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.eclipse.jetty.server.Server server> = null;
label:
return;
}
public org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent getAgent()
{
org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent v;
org.apache.activemq.transport.discovery.http.EmbeddedJettyServer v;
v := @this: org.apache.activemq.transport.discovery.http.EmbeddedJettyServer;
v = v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent agent>;
return v;
}
public void setAgent(org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent)
{
org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent v;
org.apache.activemq.transport.discovery.http.EmbeddedJettyServer v;
v := @this: org.apache.activemq.transport.discovery.http.EmbeddedJettyServer;
v := @parameter: org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent;
v.<org.apache.activemq.transport.discovery.http.EmbeddedJettyServer: org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent agent> = v;
return;
}
}