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

Engine.getPipeline介绍

暂无

代码示例

代码示例来源：origin: org.springframework.boot/spring-boot

private void configureEngine(Engine engine) {
  engine.setBackgroundProcessorDelay(this.backgroundProcessorDelay);
  for (Valve valve : this.engineValves) {
    engine.getPipeline().addValve(valve);
  }
}

代码示例来源：origin: org.springframework.boot/spring-boot

private void configureEngine(Engine engine) {
  engine.setBackgroundProcessorDelay(this.backgroundProcessorDelay);
  for (Valve valve : this.engineValves) {
    engine.getPipeline().addValve(valve);
  }
}

代码示例来源：origin: redisson/redisson

getEngine().getPipeline().addValve(new UpdateValve(this));

代码示例来源：origin: redisson/redisson

getEngine().getPipeline().addValve(new UpdateValve(this));

代码示例来源：origin: redisson/redisson

getEngine().getPipeline().addValve(new UpdateValve(this));

代码示例来源：origin: redisson/redisson

getEngine().getPipeline().addValve(new UpdateValve(this));

代码示例来源：origin: org.redisson/redisson-tomcat-8

getEngine().getPipeline().addValve(new UpdateValve(this));

代码示例来源：origin: com.tomitribe.tribestream/tribestream-container

public void setUp(@Observes final ContainerStarted ignored) {
  final StandardServer server = TomcatHelper.getServer();
  if (server == null) {
    return;
  }
  for (final Service service : server.findServices()) {
    if (Engine.class.isInstance(service.getContainer())) {
      final Engine engine = Engine.class.cast(service.getContainer());
      final Realm engineRealm = engine.getRealm();
      addTracker(engineRealm);
      engine.getPipeline().addValve(new TrackerValve());
      for (final Container engineChild : engine.findChildren()) { // we suppose we dont add host dynamically with such an algo ()case in tomee)
        if (Host.class.isInstance(engineChild)) {
          final Host host = Host.class.cast(engineChild);
          host.addContainerListener(new HostListener());
          final Realm hostRealm = host.getRealm();
          if (hostRealm == engineRealm || TrackerRealm.class.isInstance(host)) {
            continue;
          }
          addTracker(hostRealm);
        }
      }
    }
  }
}

代码示例来源：origin: org.jboss.jbossas/jboss-as-tomcat

engine.setJvmRoute(StringPropertyReplacer.replaceProperties(engineMetaData.getJvmRoute()));
engine.getPipeline().addValve(new ActiveRequestResponseCacheValve()); 
engine.setDefaultHost(engineMetaData.getDefaultHost());
service.setContainer(engine);

代码示例来源：origin: justlive1/oxygen

private void configEngine(Engine engine, TomcatConf tomcatConf) {
 engine.setBackgroundProcessorDelay(tomcatConf.getBackgroundProcessorDelay());
 if (tomcatConf.isAccessLogEnabled()) {
  AccessLogValve value = new AccessLogValve();
  value.setBuffered(tomcatConf.isAccessLogBuffered());
  value.setFileDateFormat(tomcatConf.getAccessLogFileFormat());
  value.setRequestAttributesEnabled(tomcatConf.isAccessLogRequestAttributesEnabled());
  value.setPattern(tomcatConf.getAccessLogPattern());
  engine.getPipeline().addValve(value);
 }
}

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

Pipeline pipeline = connector.getService().getContainer().getPipeline();
request.setAsyncSupported(pipeline.isAsyncSupported());
pipeline.getFirst().invoke(request, response);

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

Pipeline pipeline = connector.getService().getContainer().getPipeline();
request.setAsyncSupported(pipeline.isAsyncSupported());
pipeline.getFirst().invoke(request, response);

代码示例来源：origin: org.apache.tomee/tomee-catalina

final RouterValve routerValve = new RouterValve();
routerValve.setConfigurationPath(globalRouterConf);
engine.getPipeline().addValve(routerValve);

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

connector.getService().getContainer().getPipeline().isAsyncSupported());
connector.getService().getContainer().getPipeline().getFirst().invoke(
    request, response);

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

connector.getService().getContainer().getPipeline().isAsyncSupported());
connector.getService().getContainer().getPipeline().getFirst().invoke(
    request, response);

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

connector.getService().getContainer().getPipeline().getFirst().invoke(
    request, response);
connector.getService().getContainer().getPipeline().getFirst().invoke(
    request, response);
Throwable t = (Throwable) request.getAttribute(RequestDispatcher.ERROR_EXCEPTION);

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

connector.getService().getContainer().getPipeline().getFirst().invoke(
    request, response);
connector.getService().getContainer().getPipeline().getFirst().invoke(
    request, response);
Throwable t = (Throwable) request.getAttribute(RequestDispatcher.ERROR_EXCEPTION);