org.apache.catalina.Context.getPipeline()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(93)

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

Context.getPipeline介绍

暂无

代码示例

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

@Override
protected Pipeline getPipeline() {
 return getTheContext().getPipeline();
}

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

@Override
protected Pipeline getPipeline() {
 return getTheContext().getPipeline();
}

代码示例来源：origin: OryxProject/oryx

authenticator.setNonceValidity(10 * 1000L); // Shorten from 5 minutes to 10 seconds
authenticator.setNonceCacheSize(20000); // Increase from 1000 to 20000
context.getPipeline().addValve(authenticator);

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

context.getPipeline().addValve(valve);

代码示例来源：origin: magro/memcached-session-manager

context.getParent().getPipeline().addValve(_trackingHostValve);
_trackingContextValve = createRequestTrackingContextValve(sessionCookieName);
context.getPipeline().addValve( _trackingContextValve );

代码示例来源：origin: magro/memcached-session-manager

public void shutdown() {
  _log.info( "Stopping services." );
  _manager.getContext().getParent().getPipeline().removeValve(_trackingHostValve);
  _manager.getContext().getPipeline().removeValve(_trackingContextValve);
  _backupSessionService.shutdown();
  if ( _lockingStrategy != null ) {
    _lockingStrategy.shutdown();
  }
  if ( _storage != null ) {
    _storage.shutdown();
    _storage = null;
  }
  _transcoderFactory = null;
  _invalidSessionsCache.clear();
}

代码示例来源：origin: modcluster/mod_cluster

@Override
public void addRequestListener(final ServletRequestListener listener) {
  // Add a valve rather than using Context.setApplicationEventListeners(...), since these will be overwritten at the end of Context.start()
  if (this.valveFactory != null) {
    this.context.getPipeline().addValve(this.valveFactory.createValve(listener));
  }
}

代码示例来源：origin: org.jboss.mod_cluster/mod_cluster

/**
* {@inheritDoc}
* @see org.jboss.modcluster.Context#addRequestListener(javax.servlet.ServletRequestListener)
*/
public void addRequestListener(final ServletRequestListener listener)
{
 // Add a valve rather than using Context.setApplicationEventListeners(...), since these will be overwritten at the end of Context.start()
 this.context.getPipeline().addValve(new RequestListenerValve(listener));
}

代码示例来源：origin: modcluster/mod_cluster

@Override
public void removeRequestListener(ServletRequestListener listener) {
  if (this.valveFactory != null) {
    Valve listenerValve = this.valveFactory.createValve(listener);
    Pipeline pipeline = this.context.getPipeline();
    for (Valve valve : pipeline.getValves()) {
      if (listenerValve.equals(valve)) {
        pipeline.removeValve(valve);
        break;
      }
    }
  }
}

代码示例来源：origin: org.jboss.mod_cluster/mod_cluster

/**
* {@inheritDoc}
* @see org.jboss.modcluster.Context#removeRequestListener(javax.servlet.ServletRequestListener)
*/
public void removeRequestListener(ServletRequestListener listener)
{
 Valve listenerValve = new RequestListenerValve(listener);
 
 Pipeline pipeline = this.context.getPipeline();
 
 for (Valve valve: pipeline.getValves())
 {
   if (listenerValve.equals(valve))
   {
    pipeline.removeValve(valve);
    
    return;
   }
 }
}

代码示例来源：origin: net.rakugakibox.springbootext/spring-boot-ext-logback-access

/** {@inheritDoc} */
@Override
public void customize(Context context) {
  LogbackAccessValve valve = new LogbackAccessValve();
  valve.setProperties(properties);
  valve.setConfigurator(configurator);
  context.getPipeline().addValve(valve);
  log.debug("Added the Tomcat valve: valve=[{}] to context=[{}]", valve, context);
}

代码示例来源：origin: org.glassfish.main.web/web-core

/**
 * Tomcat style invocation.
 */
@Override
public void invoke(org.apache.catalina.connector.Request request,
          org.apache.catalina.connector.Response response)
    throws IOException, ServletException {
  Context context = preInvoke(request, response);
  if (context == null) {
    return;
  }
  // Ask this Context to process this request
  if (context.getPipeline().hasNonBasicValves() ||
      context.hasCustomPipeline()) {
    context.getPipeline().invoke(request, response);
  } else {
    context.getPipeline().getBasic().invoke(request, response);
  }
  postInvoke(request, response);
}

代码示例来源：origin: modcluster/mod_cluster

@Test
public void requestListener() throws IOException, ServletException {
  // Test addRequestListener()
  ServletRequestListener listener = mock(ServletRequestListener.class);
  Pipeline pipeline = mock(Pipeline.class);
  Valve valve = mock(Valve.class);
  when(this.context.getPipeline()).thenReturn(pipeline);
  when(this.valveFactory.createValve(same(listener))).thenReturn(valve);
  this.catalinaContext.addRequestListener(listener);
  verify(pipeline).addValve(same(valve));
  // Test removeRequestListener()
  when(this.context.getPipeline()).thenReturn(pipeline);
  when(pipeline.getValves()).thenReturn(new Valve[] { valve });
  when(this.valveFactory.createValve(same(listener))).thenReturn(valve);
  this.catalinaContext.removeRequestListener(listener);
  verify(pipeline).removeValve(same(valve));
}

代码示例来源：origin: codefollower/Tomcat-Research

@Override
public void lifecycleEvent(LifecycleEvent event) {
  try {
    Context context = (Context) event.getLifecycle();
    if (event.getType().equals(Lifecycle.CONFIGURE_START_EVENT)) {
      context.setConfigured(true);
    }
    // LoginConfig is required to process @ServletSecurity
    // annotations
    if (context.getLoginConfig() == null) {
      context.setLoginConfig(
          new LoginConfig("NONE", null, null, null));
      context.getPipeline().addValve(new NonLoginAuthenticator());
    }
  } catch (ClassCastException e) {
    return;
  }
}

代码示例来源：origin: org.apache.catalina/com.springsource.org.apache.catalina

@Override
public void lifecycleEvent(LifecycleEvent event) {
  try {
    Context context = (Context) event.getLifecycle();
    if (event.getType().equals(Lifecycle.CONFIGURE_START_EVENT)) {
      context.setConfigured(true);
    }
    // LoginConfig is required to process @ServletSecurity
    // annotations
    if (context.getLoginConfig() == null) {
      context.setLoginConfig(
          new LoginConfig("NONE", null, null, null));
      context.getPipeline().addValve(new NonLoginAuthenticator());
    }
  } catch (ClassCastException e) {
    return;
  }
}

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

@Override
public void lifecycleEvent(LifecycleEvent event) {
  try {
    Context context = (Context) event.getLifecycle();
    if (event.getType().equals(Lifecycle.CONFIGURE_START_EVENT)) {
      context.setConfigured(true);
    }
    // LoginConfig is required to process @ServletSecurity
    // annotations
    if (context.getLoginConfig() == null) {
      context.setLoginConfig(
          new LoginConfig("NONE", null, null, null));
      context.getPipeline().addValve(new NonLoginAuthenticator());
    }
  } catch (ClassCastException e) {
    return;
  }
}

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

@Override
  public void lifecycleEvent(LifecycleEvent event) {
    try {
      Context context = (Context) event.getLifecycle();
      if (event.getType().equals(Lifecycle.CONFIGURE_START_EVENT)) {
        context.setConfigured(true);
        // Process annotations
        WebAnnotationSet.loadApplicationAnnotations(context);
        // LoginConfig is required to process @ServletSecurity
        // annotations
        if (context.getLoginConfig() == null) {
          context.setLoginConfig(new LoginConfig("NONE", null, null, null));
          context.getPipeline().addValve(new NonLoginAuthenticator());
        }
      }
    } catch (ClassCastException e) {
    }
  }
}

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

@Deprecated
private static WebConstraint findLegacyConstraints(final Context context, final String[] roles, final String transportGuarantee) {
  final LoginConfig loginConfig = context.getLoginConfig();
  if (loginConfig != null || roles != null || transportGuarantee != null) {
    final WebConstraint constraint = new WebConstraint()
        .withAuthMethod(loginConfig != null && !"NONE".equalsIgnoreCase(loginConfig.getAuthMethod()) ? loginConfig.getAuthMethod() : null)
        .withTransportGuarantee(transportGuarantee)
        .withRealm(loginConfig != null ? loginConfig.getRealmName() : null)
        .withRole(roles);
    for (final Valve valve : context.getPipeline().getValves()) {
      if (SignatureAuthenticator.class.isInstance(valve) && "SIGNATURE".equals(constraint.getAuthMethod())) {
        constraint.withMandatoryHeader(SignatureAuthenticator.class.cast(valve).getHeaders().split(" "));
      } else if (info(valve).startsWith("com.tomitribe.tribestream.proxy.auth.TokenValve/")) {
        constraint.withMandatoryHeader(SystemInstance.get().getProperty("tribe.oauth2.auth.header", "Authorization"));
        if (constraint.getAuthMethod() == null) {
          constraint.withAuthMethod("JWT"); // virtual auth method but useful information
        } else {
          constraint.withAuthMethod(constraint.getAuthMethod() + "+JWT");
        }
      }
    }
    return constraint;
  }
  return null;
}

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

@Override
  public void lifecycleEvent(LifecycleEvent event) {
    try {
      Context context = (Context) event.getLifecycle();
      if (event.getType().equals(Lifecycle.CONFIGURE_START_EVENT)) {
        context.setConfigured(true);
        // Process annotations
        WebAnnotationSet.loadApplicationAnnotations(context);
        // LoginConfig is required to process @ServletSecurity
        // annotations
        if (context.getLoginConfig() == null) {
          context.setLoginConfig(new LoginConfig("NONE", null, null, null));
          context.getPipeline().addValve(new NonLoginAuthenticator());
        }
      }
    } catch (ClassCastException e) {
    }
  }
}

代码示例来源：origin: de.javakaffee.msm/memcached-session-manager

public void shutdown() {
  _log.info( "Stopping services." );
  _manager.getContext().getParent().getPipeline().removeValve(_trackingHostValve);
  _manager.getContext().getPipeline().removeValve(_trackingContextValve);
  _backupSessionService.shutdown();
  if ( _lockingStrategy != null ) {
    _lockingStrategy.shutdown();
  }
  if ( _storage != null ) {
    _storage.shutdown();
    _storage = null;
  }
  _transcoderFactory = null;
  _invalidSessionsCache.clear();
}

内容来源于网络，如有侵权，请联系作者删除！

Context

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Context类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com