org.apache.cxf.endpoint.Client.getInFaultInterceptors()方法的使用及代码示例

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

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

Client.getInFaultInterceptors介绍

暂无

代码示例

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

private void initIntercepors(Client client, AbstractBasicInterceptorProvider clientFact) {
  client.getInInterceptors().addAll(clientFact.getInInterceptors());
  client.getOutInterceptors().addAll(clientFact.getOutInterceptors());
  client.getInFaultInterceptors().addAll(clientFact.getInFaultInterceptors());
  client.getOutFaultInterceptors().addAll(clientFact.getOutFaultInterceptors());
}

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

public List<Interceptor<? extends Message>> getInFaultInterceptors() {
  if (client != null) {
    return client.getInFaultInterceptors();
  }
  return inFault;
}

代码示例来源：origin: org.apache.cxf/cxf-rt-ws-security

public List<Interceptor<? extends Message>> getInFaultInterceptors() {
  if (client != null) {
    return client.getInFaultInterceptors();
  }
  return inFault;
}

代码示例来源：origin: org.mule.modules/mule-module-cxf

@Override
protected void configureClient(Client client)
{
  // EE-1806/MULE-4404
  client.getInInterceptors().add(new StreamClosingInterceptor());
  client.getInFaultInterceptors().add(new StreamClosingInterceptor());
}

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

private void initIntercepors(Client client, AbstractBasicInterceptorProvider clientFact) {
  client.getInInterceptors().addAll(clientFact.getInInterceptors());
  client.getOutInterceptors().addAll(clientFact.getOutInterceptors());
  client.getInFaultInterceptors().addAll(clientFact.getInFaultInterceptors());
  client.getOutFaultInterceptors().addAll(clientFact.getOutFaultInterceptors());
}

代码示例来源：origin: org.kantega.respiro/respiro-message-collector-plugin

client.getInFaultInterceptors().add(inInterceptor);

代码示例来源：origin: org.mule.modules/mule-module-cxf

protected void addMuleInterceptors()
{
  if (enableMuleSoapHeaders && !configuration.isEnableMuleSoapHeaders())
  {
    client.getInInterceptors().add(new MuleHeadersInInterceptor());
    client.getInFaultInterceptors().add(new MuleHeadersInInterceptor());
    client.getOutInterceptors().add(new MuleHeadersOutInterceptor());
    client.getOutFaultInterceptors().add(new MuleHeadersOutInterceptor());
  }
}

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

@Override
public void initialize(Client client, Bus bus) {
  createDefaultProvidersIfNeeded(bus);
  //can optimize for client case and just put interceptors it needs
  MetricsMessageOutInterceptor out = new MetricsMessageOutInterceptor(providers);
  CountingOutInterceptor countingOut = new CountingOutInterceptor();
  client.getInInterceptors().add(new MetricsMessageInInterceptor(providers));
  client.getInInterceptors().add(new MetricsMessageInPostInvokeInterceptor(providers));
  client.getInFaultInterceptors().add(new MetricsMessageInPostInvokeInterceptor(providers));
  client.getOutInterceptors().add(countingOut);
  client.getOutInterceptors().add(out);
  client.getOutInterceptors().add(new MetricsMessageClientOutInterceptor(providers));
}

代码示例来源：origin: org.apache.cxf/cxf-rt-features-metrics

@Override
public void initialize(Client client, Bus bus) {
  createDefaultProvidersIfNeeded(bus);
  //can optimize for client case and just put interceptors it needs
  MetricsMessageOutInterceptor out = new MetricsMessageOutInterceptor(providers);
  CountingOutInterceptor countingOut = new CountingOutInterceptor();
  client.getInInterceptors().add(new MetricsMessageInInterceptor(providers));
  client.getInInterceptors().add(new MetricsMessageInPostInvokeInterceptor(providers));
  client.getInFaultInterceptors().add(new MetricsMessageInPostInvokeInterceptor(providers));
  client.getOutInterceptors().add(countingOut);
  client.getOutInterceptors().add(out);
  client.getOutInterceptors().add(new MetricsMessageClientOutInterceptor(providers));
}

代码示例来源：origin: org.openehealth.ipf.commons/ipf-commons-ihe-ws

@Override
  protected void configureInterceptors(Client client) {
    super.configureInterceptors(client);

    // install auditing-related interceptors if the user has not switched auditing off
    if (auditStrategy != null) {
      if (wsTransactionConfiguration.isAuditRequestPayload()) {
        installPayloadInterceptors(client);
      }

      client.getOutInterceptors().add(new AuditOutRequestInterceptor<>(
          auditStrategy, auditContext, correlator, getWsTransactionConfiguration()));

      AuditResponseInterceptor<AuditDatasetType> auditInterceptor =
          new AuditResponseInterceptor<>(auditStrategy, auditContext, false, correlator, false);
      client.getInInterceptors().add(auditInterceptor);
      client.getInFaultInterceptors().add(auditInterceptor);
    }
  }
}

代码示例来源：origin: org.openehealth.ipf.commons/ipf-commons-ihe-ws

client.getInInterceptors().add(mapCodec);
client.getInInterceptors().add(mapAggregator);
client.getInFaultInterceptors().add(mapCodec);
client.getInFaultInterceptors().add(mapAggregator);
client.getOutInterceptors().add(mapCodec);
client.getOutInterceptors().add(mapAggregator);

代码示例来源：origin: org.jboss.ws.cxf/jbossws-cxf-client

private void cleanupPreviousProps(Client client) {
   Endpoint ep = client.getEndpoint();
   String[] previousProps = (String[])ep.get(JBOSSWS_CXF_CLIENT_CONF_PROPS);
   if (previousProps != null) {
     for (String p : previousProps) {
      if (Constants.CXF_IN_INTERCEPTORS_PROP.equals(p)) {
        InterceptorUtils.removeInterceptors(client.getInInterceptors(), (String)ep.get(p));
      } else if (Constants.CXF_OUT_INTERCEPTORS_PROP.equals(p)) {
        InterceptorUtils.removeInterceptors(client.getOutInterceptors(), (String)ep.get(p));
      } else if (Constants.CXF_IN_FAULT_INTERCEPTORS_PROP.equals(p)) {
        InterceptorUtils.removeInterceptors(client.getInFaultInterceptors(), (String)ep.get(p));
      } else if (Constants.CXF_OUT_FAULT_INTERCEPTORS_PROP.equals(p)) {
        InterceptorUtils.removeInterceptors(client.getOutFaultInterceptors(), (String)ep.get(p));
      } else if (Constants.CXF_FEATURES_PROP.equals(p)) {
        Loggers.ROOT_LOGGER.couldNoRemoveFeaturesOnClient((String)ep.get(p));
      }
      ep.remove(p);
     }
     ep.remove(JBOSSWS_CXF_CLIENT_CONF_PROPS);
   }
  }
}

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

client.getInFaultInterceptors().addAll(inFault);
client.getInInterceptors().addAll(in);
client.getOutInterceptors().addAll(out);

代码示例来源：origin: org.apache.cxf/cxf-rt-ws-security

client.getInFaultInterceptors().addAll(inFault);
client.getInInterceptors().addAll(in);
client.getOutInterceptors().addAll(out);

代码示例来源：origin: org.apache.camel/camel-cxf

protected void removeFaultInInterceptorFromClient(Client client) {
  removeInterceptors(client.getInFaultInterceptors(), REMOVING_FAULT_IN_INTERCEPTORS);
  removeInterceptors(client.getEndpoint().getService().getInFaultInterceptors(), REMOVING_FAULT_IN_INTERCEPTORS);
  removeInterceptors(client.getEndpoint().getInFaultInterceptors(), REMOVING_FAULT_IN_INTERCEPTORS);
  removeInterceptors(client.getEndpoint().getBinding().getInFaultInterceptors(), REMOVING_FAULT_IN_INTERCEPTORS);
}

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

c.getInFaultInterceptors().addAll(getInFaultInterceptors());

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

protected void initializeInterceptors(Exchange ex, PhaseInterceptorChain chain) {
  Endpoint e = ex.getEndpoint();
  Client c = ex.get(Client.class);
  InterceptorProvider ip = ex.get(InterceptorProvider.class);
  chain.add(getBus().getInFaultInterceptors());
  if (c != null) {
    chain.add(c.getInFaultInterceptors());
  } else if (ip != null) {
    chain.add(ip.getInFaultInterceptors());
  }
  chain.add(e.getService().getInFaultInterceptors());
  chain.add(e.getInFaultInterceptors());
  chain.add(e.getBinding().getInFaultInterceptors());
  if (e.getService().getDataBinding() instanceof InterceptorProvider) {
    chain.add(((InterceptorProvider)e.getService().getDataBinding()).getInFaultInterceptors());
  }
  addToChain(chain, ex.getInFaultMessage());
  addToChain(chain, ex.getOutMessage());
}
private void addToChain(PhaseInterceptorChain chain, Message m) {

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

protected void initializeInterceptors(Exchange ex, PhaseInterceptorChain chain) {
  Endpoint e = ex.getEndpoint();
  Client c = ex.get(Client.class);
  InterceptorProvider ip = ex.get(InterceptorProvider.class);
  chain.add(getBus().getInFaultInterceptors());
  if (c != null) {
    chain.add(c.getInFaultInterceptors());
  } else if (ip != null) {
    chain.add(ip.getInFaultInterceptors());
  }
  chain.add(e.getService().getInFaultInterceptors());
  chain.add(e.getInFaultInterceptors());
  chain.add(e.getBinding().getInFaultInterceptors());
  if (e.getService().getDataBinding() instanceof InterceptorProvider) {
    chain.add(((InterceptorProvider)e.getService().getDataBinding()).getInFaultInterceptors());
  }
  addToChain(chain, ex.getInFaultMessage());
  addToChain(chain, ex.getOutMessage());
}
private void addToChain(PhaseInterceptorChain chain, Message m) {

代码示例来源：origin: org.apache.cxf/cxf-bundle-jaxrs

protected void initializeInterceptors(Exchange ex, PhaseInterceptorChain chain) {
  Endpoint e = ex.get(Endpoint.class);
  Client c = ex.get(Client.class);
  InterceptorProvider ip = ex.get(InterceptorProvider.class);
  
  chain.add(getBus().getInFaultInterceptors());
  if (c != null) {
    chain.add(c.getInFaultInterceptors());
  } else if (ip != null) {
    chain.add(ip.getInFaultInterceptors());
  }
  chain.add(e.getService().getInFaultInterceptors());
  chain.add(e.getInFaultInterceptors());
  chain.add(e.getBinding().getInFaultInterceptors());
  if (e.getService().getDataBinding() instanceof InterceptorProvider) {
    chain.add(((InterceptorProvider)e.getService().getDataBinding()).getInFaultInterceptors());
  }
  
  addToChain(chain, ex.getInFaultMessage());
  addToChain(chain, ex.getOutMessage());
}
private void addToChain(PhaseInterceptorChain chain, Message m) {

代码示例来源：origin: org.apache.cxf/cxf-api

protected void initializeInterceptors(Exchange ex, PhaseInterceptorChain chain) {
  Endpoint e = ex.get(Endpoint.class);
  Client c = ex.get(Client.class);
  InterceptorProvider ip = ex.get(InterceptorProvider.class);
  
  chain.add(getBus().getInFaultInterceptors());
  if (c != null) {
    chain.add(c.getInFaultInterceptors());
  } else if (ip != null) {
    chain.add(ip.getInFaultInterceptors());
  }
  chain.add(e.getService().getInFaultInterceptors());
  chain.add(e.getInFaultInterceptors());
  chain.add(e.getBinding().getInFaultInterceptors());
  if (e.getService().getDataBinding() instanceof InterceptorProvider) {
    chain.add(((InterceptorProvider)e.getService().getDataBinding()).getInFaultInterceptors());
  }
  
  addToChain(chain, ex.getInFaultMessage());
  addToChain(chain, ex.getOutMessage());
}
private void addToChain(PhaseInterceptorChain chain, Message m) {

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

Client

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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