本文整理了Java中org.mortbay.jetty.Server.start()
方法的一些代码示例,展示了Server.start()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Server.start()
方法的具体详情如下:
包路径:org.mortbay.jetty.Server
类名称:Server
方法名:start
暂无
代码示例来源:origin: soabase/exhibitor
public void start() throws Exception
{
server.start();
}
代码示例来源:origin: tjake/Solandra
public void start(boolean waitForSolr) throws Exception
{
if(!server.isRunning() ) {
server.start();
}
if (waitForSolr) waitForSolr(context);
}
代码示例来源:origin: ltsopensource/light-task-scheduler
server.setHandler(webapp);
server.setStopAtShutdown(true);
server.start();
代码示例来源:origin: Netflix/eureka
public void start() throws Exception {
server.start();
port = server.getConnectors()[0].getLocalPort();
}
代码示例来源:origin: azkaban/azkaban
private void prepareAndStartServer()
throws Exception {
validateDatabaseVersion();
createThreadPool();
configureRoutes();
// Todo jamiesjc: enable web metrics for azkaban poll model later
if (this.props.getBoolean(Constants.ConfigurationKeys.IS_METRICS_ENABLED, false)
&& !this.props.getBoolean(ConfigurationKeys.AZKABAN_POLL_MODEL, false)) {
startWebMetrics();
}
if (this.props.getBoolean(ConfigurationKeys.ENABLE_QUARTZ, false)) {
// flowTriggerService needs to be started first before scheduler starts to schedule
// existing flow triggers
logger.info("starting flow trigger service");
this.flowTriggerService.start();
logger.info("starting flow trigger scheduler");
this.scheduler.start();
}
try {
this.server.start();
logger.info("Server started");
} catch (final Exception e) {
logger.warn(e);
Utils.croak(e.getMessage(), 1);
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public String getRedirectUri() throws IOException {
if ( this.port == -1 ) {
this.port = getUnusedPort();
}
this.server = new Server( this.port );
Connector[] arr$ = this.server.getConnectors();
int len$ = arr$.length;
for ( int i$ = 0; i$ < len$; ++i$ ) {
Connector c = arr$[i$];
c.setHost( this.host );
}
this.server.addHandler( new CustomLocalServerReceiver.CallbackHandler() );
try {
this.server.start();
} catch ( Exception var5 ) {
Throwables.propagateIfPossible( var5 );
throw new IOException( var5 );
}
return "http://" + this.host + ":" + this.port + "/Callback/success.html";
}
代码示例来源:origin: twitter/ambrose
server.start();
server.join();
} catch (Exception e) {
代码示例来源:origin: Netflix/eureka
public void start() throws Exception {
server = new Server(port);
server.setHandler(new AppsResourceHandler());
server.start();
port = server.getConnectors()[0].getLocalPort();
}
代码示例来源:origin: testcontainers/testcontainers-java
@Before
public void setupLocalServer() throws Exception {
// Set up a local Jetty HTTP server
Server server = new Server();
server.addConnector(new SocketConnector());
ResourceHandler resourceHandler = new ResourceHandler();
resourceHandler.setResourceBase("src/test/resources/server");
server.addHandler(resourceHandler);
server.start();
// The server will have a random port assigned, so capture that
localPort = server.getConnectors()[0].getLocalPort();
}
代码示例来源:origin: rhuss/jolokia
/**
* Startup the HTTP server
*
* @throws StartException if starting fails
*/
public void start() throws StartException {
try {
server.start();
} catch (Exception e) {
throw new StartException(e, parent);
}
}
代码示例来源:origin: voldemort/voldemort
public static Context getJettyServer(String clusterXml,
String storesXml,
String storeName,
RequestFormatType requestFormat,
int port) throws Exception {
StoreRepository repository = getStores(storeName, clusterXml, storesXml);
// initialize servlet
Server server = new Server(port);
server.setSendServerVersion(false);
Context context = new Context(server, "/", Context.NO_SESSIONS);
RequestHandler handler = getSocketRequestHandlerFactory(clusterXml, storesXml, repository).getRequestHandler(requestFormat);
context.addServlet(new ServletHolder(new StoreServlet(handler)), "/stores");
server.start();
return context;
}
代码示例来源:origin: voldemort/voldemort
this.context = context;
this.httpServer = httpServer;
this.httpServer.start();
logger.info("HTTP service started on port " + this.port);
} catch(Exception e) {
代码示例来源:origin: mapsforge/mapsforge
@Before
public final void beforeTest() throws Exception {
Assert.assertFalse(this.httpRoot.exists());
Assert.assertTrue(this.httpRoot.mkdirs());
Context context = new Context(this.server, "/", Context.SESSIONS);
context.setBaseResource(new FileResource(new URL("file://" + this.httpRoot.getAbsolutePath())));
context.setContextPath("/");
context.addServlet(new ServletHolder(new DefaultServlet()), "/*");
this.server.setHandler(context);
this.server.start();
}
代码示例来源:origin: info.aduna.commons/aduna-commons-net-http-server-embedded
public void start()
throws Exception
{
jetty.start();
}
代码示例来源:origin: it.unimi.dsi/mg4j-big
public void run() {
try {
SERVER.start();
}
catch ( Exception e ) {
throw new RuntimeException();
}
}
}.start();
代码示例来源:origin: org.ctoolkit.test/ctoolkit-test
public void start()
{
try
{
server.start();
}
catch ( Exception e )
{
throw new RuntimeException( e );
}
}
}
代码示例来源:origin: org.dspace.dependencies.solr/dspace-solr-server
public void start(boolean waitForSolr) throws Exception
{
if(!server.isRunning() ) {
server.start();
}
if (waitForSolr) waitForSolr(context);
}
代码示例来源:origin: org.mortbay.jetty/jetty-embedded
public static void main(String[] args)
throws Exception
{
Server server = new Server();
Connector connector=new SocketConnector();
connector.setPort(8080);
server.setConnectors(new Connector[]{connector});
Handler handler=new HelloHandler();
server.setHandler(handler);
server.start();
server.join();
}
代码示例来源:origin: org.apache.axis2/axis2-transport-testkit
@Setup @SuppressWarnings("unused")
private void setUp(HttpTestEnvironment env) throws Exception {
server = new Server();
SocketListener listener = new SocketListener();
listener.setPort(env.getServerPort());
server.addListener(listener);
context = new HttpContext(server, Channel.CONTEXT_PATH + "/*");
server.start();
}
代码示例来源:origin: org.apache.avro/avro-ipc
public StatsServer(StatsPlugin plugin, int port) throws Exception {
this.httpServer = new Server(port);
this.plugin = plugin;
Context staticContext = new Context(httpServer, "/static");
staticContext.addServlet(new ServletHolder(new StaticServlet()), "/");
Context context = new Context(httpServer, "/");
context.addServlet(new ServletHolder(new StatsServlet(plugin)), "/");
httpServer.start();
}
内容来源于网络,如有侵权,请联系作者删除!