本文整理了Java中org.mortbay.jetty.Connector.open()方法的一些代码示例，展示了Connector.open()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Connector.open()方法的具体详情如下：
包路径：org.mortbay.jetty.Connector
类名称：Connector
方法名：open

Connector.open介绍

[英]Opens the connector
[中]打开连接器

代码示例

代码示例来源：origin: stackoverflow.com

Connector dbkonek;
if(proses == 3){
  dbkonek = new HistoryConnector(this);
}else{  
  dbkonek = new DatabaseConnector(this);
}
dbkonek.open();
...

代码示例来源：origin: apache/hama

+ "getLocalPort() before open() is " + port
  + ". Opening the listener on " + oriPort);
listener.open();
port = listener.getLocalPort();
LOG.info("listener.getLocalPort() returned "
  Thread.sleep(1000);
  listener.setPort(oriPort == 0 ? 0 : (oriPort += 1));
  listener.open();
  Thread.sleep(100);
  port = listener.getLocalPort();
  listener.open();
  Thread.sleep(100);
  webServer.start();

代码示例来源：origin: com.facebook.hadoop/hadoop-core

"getLocalPort() before open() is "+ port + 
    ". Opening the listener on " + oriPort);
listener.open();
port = listener.getLocalPort();
LOG.info("listener.getLocalPort() returned " + listener.getLocalPort() + 
  Thread.sleep(1000);
  listener.setPort(oriPort == 0 ? 0 : (oriPort += 1));
  listener.open();
  Thread.sleep(100);
  port = listener.getLocalPort();
  listener.open();
  Thread.sleep(100);
  webServer.start();

代码示例来源：origin: org.apache.hama/hama-core

+ "getLocalPort() before open() is " + port
  + ". Opening the listener on " + oriPort);
listener.open();
port = listener.getLocalPort();
LOG.info("listener.getLocalPort() returned "
  Thread.sleep(1000);
  listener.setPort(oriPort == 0 ? 0 : (oriPort += 1));
  listener.open();
  Thread.sleep(100);
  port = listener.getLocalPort();
  listener.open();
  Thread.sleep(100);
  webServer.start();

代码示例来源：origin: org.apache.tajo/tajo-core

+ "getLocalPort() before open() is " + port
  + ". Opening the listener on " + oriPort);
listener.open();
port = listener.getLocalPort();
LOG.debug("listener.getLocalPort() returned "
  Thread.sleep(1000);
  listener.setPort(oriPort == 0 ? 0 : (oriPort += 1));
  listener.open();
  Thread.sleep(100);
  port = listener.getLocalPort();

代码示例来源：origin: io.fabric8/fabric-hadoop

"getLocalPort() before open() is "+ port + 
    ". Opening the listener on " + oriPort);
listener.open();
port = listener.getLocalPort();
LOG.info("listener.getLocalPort() returned " + listener.getLocalPort() + 
  Thread.sleep(1000);
  listener.setPort(oriPort == 0 ? 0 : (oriPort += 1));
  listener.open();
  Thread.sleep(100);
  port = listener.getLocalPort();

代码示例来源：origin: apache/tajo

+ "getLocalPort() before open() is " + port
  + ". Opening the listener on " + oriPort);
listener.open();
port = listener.getLocalPort();
LOG.debug("listener.getLocalPort() returned "
  Thread.sleep(1000);
  listener.setPort(oriPort == 0 ? 0 : (oriPort += 1));
  listener.open();
  Thread.sleep(100);
  port = listener.getLocalPort();

代码示例来源：origin: ch.cern.hadoop/hadoop-common

listener.open();
 break;
} catch (BindException ex) {

代码示例来源：origin: io.hops/hadoop-common

listener.open();
 break;
} catch (BindException ex) {

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

listener.open();
 break;
} catch (BindException ex) {

代码示例来源：origin: io.hops/hadoop-common

listener.open();
LOG.info("Jetty bound to port " + listener.getLocalPort());
break;

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

listener.open();
LOG.info("Jetty bound to port " + listener.getLocalPort());
break;

代码示例来源：origin: io.hops/hadoop-common

listener.open();
LOG.info("Jetty bound to port " + listener.getLocalPort());
break;

代码示例来源：origin: ch.cern.hadoop/hadoop-common

listener.open();
LOG.info("Jetty bound to port " + listener.getLocalPort());
break;

代码示例来源：origin: org.apache.slider/slider-core

private void openListeners() throws Exception {
 // from HttpServer2.openListeners()
 for (Connector listener : agentServer.getConnectors()) {
  if (listener.getLocalPort() != -1) {
   // This listener is either started externally or has been bound
   continue;
  }
  int port = listener.getPort();
  while (true) {
   // jetty has a bug where you can't reopen a listener that previously
   // failed to open w/o issuing a close first, even if the port is changed
   try {
    listener.close();
    listener.open();
    LOG.info("Jetty bound to port " + listener.getLocalPort());
    break;
   } catch (BindException ex) {
    if (port == 0) {
     BindException be = new BindException("Port in use: "
       + listener.getHost() + ":" + listener.getPort());
     be.initCause(ex);
     throw be;
    }
   }
   // try the next port number
   listener.setPort(++port);
   Thread.sleep(100);
  }
 }
}

代码示例来源：origin: apache/incubator-slider

private void openListeners() throws Exception {
 // from HttpServer2.openListeners()
 for (Connector listener : agentServer.getConnectors()) {
  if (listener.getLocalPort() != -1) {
   // This listener is either started externally or has been bound
   continue;
  }
  int port = listener.getPort();
  while (true) {
   // jetty has a bug where you can't reopen a listener that previously
   // failed to open w/o issuing a close first, even if the port is changed
   try {
    listener.close();
    listener.open();
    LOG.info("Jetty bound to port " + listener.getLocalPort());
    break;
   } catch (BindException ex) {
    if (port == 0) {
     BindException be = new BindException("Port in use: "
       + listener.getHost() + ":" + listener.getPort());
     be.initCause(ex);
     throw be;
    }
   }
   // try the next port number
   listener.setPort(++port);
   Thread.sleep(100);
  }
 }
}