本文整理了Java中org.apache.catalina.Service.findConnectors()
方法的一些代码示例,展示了Service.findConnectors()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Service.findConnectors()
方法的具体详情如下:
包路径:org.apache.catalina.Service
类名称:Service
方法名:findConnectors
[英]Find and return the set of Connectors associated with this Service.
[中]查找并返回与此服务关联的连接器集。
代码示例来源:origin: org.springframework.boot/spring-boot
private String getPortsDescription(boolean localPort) {
StringBuilder ports = new StringBuilder();
for (Connector connector : this.tomcat.getService().findConnectors()) {
if (ports.length() != 0) {
ports.append(' ');
}
int port = localPort ? connector.getLocalPort() : connector.getPort();
ports.append(port).append(" (").append(connector.getScheme()).append(')');
}
return ports.toString();
}
代码示例来源:origin: SonarSource/sonarqube
void log(Tomcat tomcat) {
Connector[] connectors = tomcat.getService().findConnectors();
for (Connector connector : connectors) {
if (StringUtils.equalsIgnoreCase(connector.getScheme(), "http")) {
logHttp(connector);
} else {
throw new IllegalArgumentException("Unsupported connector: " + connector);
}
}
}
代码示例来源:origin: org.springframework.boot/spring-boot
private void removeServiceConnectors() {
for (Service service : this.tomcat.getServer().findServices()) {
Connector[] connectors = service.findConnectors().clone();
this.serviceConnectors.put(service, connectors);
for (Connector connector : connectors) {
service.removeConnector(connector);
}
}
}
代码示例来源:origin: stackoverflow.com
Server server = ServerFactory.getServer();
Service[] services = server.findServices();
for (Service service : services) {
for (Connector connector : service.findConnectors()) {
ProtocolHandler protocolHandler = connector.getProtocolHandler();
if (protocolHandler instanceof Http11Protocol
|| protocolHandler instanceof Http11AprProtocol
|| protocolHandler instanceof Http11NioProtocol) {
serverPort = connector.getPort();
System.out.println("HTTP Port: " + connector.getPort());
}
}
}
代码示例来源:origin: org.springframework.boot/spring-boot
private void checkThatConnectorsHaveStarted() {
checkConnectorHasStarted(this.tomcat.getConnector());
for (Connector connector : this.tomcat.getService().findConnectors()) {
checkConnectorHasStarted(connector);
}
}
代码示例来源:origin: SonarSource/sonarqube
@Test
public void unsupported_connector() {
Connector connector = mock(Connector.class, Mockito.RETURNS_DEEP_STUBS);
when(connector.getProtocol()).thenReturn("SPDY/1.1");
when(connector.getScheme()).thenReturn("spdy");
when(tomcat.getService().findConnectors()).thenReturn(new Connector[] {connector});
try {
underTest.log(tomcat);
fail();
} catch (IllegalArgumentException e) {
// expected
}
}
代码示例来源:origin: SonarSource/sonarqube
@Test
public void logHttp() {
Connector connector = newConnector("HTTP/1.1", "http");
when(tomcat.getService().findConnectors()).thenReturn(new Connector[] {connector});
underTest.log(tomcat);
verify(logger).info("HTTP connector enabled on port 1234");
verifyNoMoreInteractions(logger);
}
代码示例来源:origin: SonarSource/sonarqube
@Test
public void fail_with_IAE_on_unsupported_protocol() {
Connector connector = newConnector("AJP/1.3", "ajp");
when(tomcat.getService().findConnectors()).thenReturn(new Connector[] {connector});
expectedException.expect(IllegalArgumentException.class);
expectedException.expectMessage("Unsupported connector: Connector[AJP/1.3-1234]");
underTest.log(tomcat);
}
代码示例来源:origin: line/armeria
@Test
public void verifySingleConnector() {
// Relevant to Tomcat 9.0
assertThat(applicationContext).isInstanceOf(WebServerApplicationContext.class);
WebServer webServer = ((WebServerApplicationContext) applicationContext).getWebServer();
assertThat(webServer).isInstanceOf(TomcatWebServer.class);
assertThat(((TomcatWebServer) webServer).getTomcat()
.getEngine()
.getService()
.findConnectors()).hasSize(1);
}
代码示例来源:origin: line/armeria
final Connector[] connectors = expectedService.findConnectors();
if (connectors == null || Arrays.stream(connectors).noneMatch(c -> c == expectedConnector)) {
throw new TomcatServiceException("A configurator should never remove the default connector.");
代码示例来源:origin: stackoverflow.com
for (Connector connector : service.findConnectors()) {
System.out.println(connector);
String uriEncoding = connector.getURIEncoding();
代码示例来源:origin: psi-probe/psi-probe
@Override
public void setWrapper(Wrapper wrapper) {
Valve valve = createValve();
if (wrapper != null) {
host = (Host) wrapper.getParent().getParent();
Engine engine = (Engine) host.getParent();
Service service = engine.getService();
connectors = service.findConnectors();
try {
deployerOName =
new ObjectName(host.getParent().getName() + ":type=Deployer,host=" + host.getName());
} catch (MalformedObjectNameException e) {
logger.trace("", e);
}
host.getPipeline().addValve(valve);
mbeanServer = ManagementFactory.getPlatformMBeanServer();
} else if (host != null) {
host.getPipeline().removeValve(valve);
}
}
代码示例来源:origin: org.apache.meecrowave/meecrowave-core
private Connector findFirstConnector() {
return Stream.of(tomcat.getServer().findServices())
.flatMap(s -> Stream.of(s.findConnectors()))
.findFirst()
.orElse(null);
}
代码示例来源:origin: org.apache.meecrowave/meecrowave-core
private void server(final Server s) {
server = s;
connector = server != null && server.findServices().length > 0 && server.findServices()[0].findConnectors().length > 0 ?
server.findServices()[0].findConnectors()[0] : null;
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
private Connector[] getConnectors() {
Engine e = (Engine) host.getParent();
Service s = e.getService();
return s.findConnectors();
}
}
代码示例来源:origin: org.apache.geronimo.modules/geronimo-tomcat6
public void doStart() throws Exception {
Connector[] connectors = server.getService(null).findConnectors();
for (Connector conn : connectors) {
this.buildConnectorGBean(classLoader, kernel, conn, container);
}
}
代码示例来源:origin: org.sonarsource.sonarqube/sonar-server
void log(Tomcat tomcat) {
Connector[] connectors = tomcat.getService().findConnectors();
for (Connector connector : connectors) {
if (StringUtils.equalsIgnoreCase(connector.getScheme(), "http")) {
logHttp(connector);
} else {
throw new IllegalArgumentException("Unsupported connector: " + connector);
}
}
}
代码示例来源:origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core
private Connector[] getConnectors() {
Engine e = (Engine) host.getParent();
Service s = e.getService();
return s.findConnectors();
}
}
代码示例来源:origin: org.apache.openejb/openejb-tomcat-catalina
public TomcatWsRegistry() {
StandardServer standardServer = (StandardServer) ServerFactory.getServer();
for (Service service : standardServer.findServices()) {
if (service.getContainer() instanceof Engine) {
connectors = Arrays.asList(service.findConnectors());
engine = (Engine) service.getContainer();
break;
}
}
}
代码示例来源:origin: org.apache.tomee/tomee-jaxrs
public TomcatRsRegistry() {
for (final Service service : TomcatHelper.getServer().findServices()) {
if (service.getContainer() instanceof Engine) {
connectors = Arrays.asList(service.findConnectors());
break;
}
}
hosts = SystemInstance.get().getComponent(Hosts.class);
}
内容来源于网络,如有侵权,请联系作者删除!