org.jboss.wsf.spi.deployment.Endpoint.getRecordProcessors()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(135)

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

Endpoint.getRecordProcessors介绍

[英]Get the record processors configured for this endpoint
[中]获取为此终结点配置的记录处理器

代码示例

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

public List<RecordProcessor> getRecordProcessors()
{
 return endpoint.getRecordProcessors();
}

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

public List<RecordProcessor> getRecordProcessors()
{
 return endpoint.getRecordProcessors();
}

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

/**
* Returns true if there's at least a record processor in recording mode
* 
* @param endpoint
* @return
*/
private boolean isRecording(Endpoint endpoint)
{
 List<RecordProcessor> processors = endpoint.getRecordProcessors();
 if (processors == null || processors.isEmpty())
 {
   return false;
 }
 for (RecordProcessor processor : processors)
 {
   if (processor.isRecording())
   {
    return true;
   }
 }
 return false;
}

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

/**
* Returns true if there's at least a record processor in recording mode
* 
* @param endpoint
* @return
*/
private boolean isRecording(Endpoint endpoint)
{
 List<RecordProcessor> processors = endpoint.getRecordProcessors();
 if (processors == null || processors.isEmpty())
 {
   return false;
 }
 for (RecordProcessor processor : processors)
 {
   if (processor.isRecording())
   {
    return true;
   }
 }
 return false;
}

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

@Override
public void stop(Deployment dep)
{
 for (Endpoint ep : dep.getService().getEndpoints())
 {
   List<RecordProcessor> processors = ep.getRecordProcessors();
   for (RecordProcessor processor : processors)
   {
    this.unregisterRecordProcessor(processor, ep);
   }
 }
}

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

@Override
public void stop(Deployment dep)
{
 for (Endpoint ep : dep.getService().getEndpoints())
 {
   List<RecordProcessor> processors = ep.getRecordProcessors();
   for (RecordProcessor processor : processors)
   {
    this.unregisterRecordProcessor(processor, ep);
   }
 }
}

代码示例来源：origin: org.jboss.eap/wildfly-webservices-server-integration

@Override
public void stop(final StopContext context) {
  WSLogger.ROOT_LOGGER.stopping(name);
  endpoint.getLifecycleHandler().stop(endpoint);
  endpoint.setSecurityDomainContext(null);
  unregisterEndpoint(endpoint);
  final List<RecordProcessor> processors = endpoint.getRecordProcessors();
  for (final RecordProcessor processor : processors) {
    unregisterRecordProcessor(processor, endpoint);
  }
}

代码示例来源：origin: org.wildfly/wildfly-webservices-server-integration

@Override
public void stop(final StopContext context) {
  WSLogger.ROOT_LOGGER.stopping(name);
  ServiceContainerEndpointRegistry.unregister(aliasName, endpoint);
  endpoint.getLifecycleHandler().stop(endpoint);
  endpoint.setSecurityDomainContext(null);
  unregisterEndpoint(endpoint);
  final List<RecordProcessor> processors = endpoint.getRecordProcessors();
  for (final RecordProcessor processor : processors) {
    unregisterRecordProcessor(processor, endpoint);
  }
}

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

record.setOperation((QName)ctx.get(MessageContext.WSDL_OPERATION));
boolean processEnvelope = false;
for (Iterator<RecordProcessor> it = endpoint.getRecordProcessors().iterator(); it.hasNext() && !processEnvelope; )

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

public void setRecordProcessors(List<RecordProcessor> processors)
 for (RecordProcessor processor : endpoint.getRecordProcessors())

代码示例来源：origin: org.jboss.as/jboss-as-webservices-server-integration

@Override
public void stop(final StopContext context) {
  ROOT_LOGGER.stopping(name);
  endpoint.setSecurityDomainContext(null);
  if (hasWebservicesMD(endpoint)) {
    pclWebAppControllerValue.getValue().decrementUsers();
  }
  endpointRegistryValue.getValue().unregister(endpoint);
  final List<RecordProcessor> processors = endpoint.getRecordProcessors();
  for (final RecordProcessor processor : processors) {
    unregisterRecordProcessor(processor, endpoint);
  }
}

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

record.setOperation((QName)ctx.get(MessageContext.WSDL_OPERATION));
boolean processEnvelope = false;
for (Iterator<RecordProcessor> it = endpoint.getRecordProcessors().iterator(); it.hasNext() && !processEnvelope; )

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

record.setOperation((QName)ctx.get(MessageContext.WSDL_OPERATION));
boolean processEnvelope = false;
for (Iterator<RecordProcessor> it = endpoint.getRecordProcessors().iterator(); it.hasNext() && !processEnvelope; )

代码示例来源：origin: org.jboss.as/jboss-as-webservices-server-integration

@Override
public void start(final StartContext context) throws StartException {
  ROOT_LOGGER.starting(name);
  endpoint.setSecurityDomainContext(new SecurityDomainContextAdaptor(securityDomainContextValue.getValue()));
  if (hasWebservicesMD(endpoint)) { //basically JAX-RPC deployments require the PortComponentLinkServlet to be available
    pclWebAppControllerValue.getValue().incrementUsers();
  }
  final List<RecordProcessor> processors = endpoint.getRecordProcessors();
  for (final RecordProcessor processor : processors) {
    registerRecordProcessor(processor, endpoint);
  }
  endpointRegistryValue.getValue().register(endpoint);
}

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

record.setOperation((QName)ctx.get(MessageContext.WSDL_OPERATION));
boolean processEnvelope = false;
for (Iterator<RecordProcessor> it = endpoint.getRecordProcessors().iterator(); it.hasNext() && !processEnvelope; )

代码示例来源：origin: org.wildfly/wildfly-webservices-server-integration

@Override
public void start(final StartContext context) {
  WSLogger.ROOT_LOGGER.starting(name);
  final String domainName = (String)endpoint.getProperty(SECURITY_DOMAIN_NAME);
  if (isElytronSecurityDomain(endpoint, domainName)) {
    if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
      endpoint.setSecurityDomainContext(new ElytronSecurityDomainContextImpl(this.ejbApplicationSecurityDomain.get().getSecurityDomain()));
    } else {
      endpoint.setSecurityDomainContext(new ElytronSecurityDomainContextImpl(this.elytronSecurityDomain.get()));
    }
  } else {
    endpoint.setSecurityDomainContext(new SecurityDomainContextImpl(securityDomainContext.get()));
  }
  if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
    final EJBViewMethodSecurityAttributesService ejbMethodSecurityAttributeService = this.ejbMethodSecurityAttributeService.get();
    endpoint.addAttachment(EJBMethodSecurityAttributeProvider.class, new EJBMethodSecurityAttributesAdaptor(ejbMethodSecurityAttributeService));
  }
  final List<RecordProcessor> processors = endpoint.getRecordProcessors();
  for (final RecordProcessor processor : processors) {
    registerRecordProcessor(processor, endpoint);
  }
  final EndpointMetricsFactory endpointMetricsFactory = SPIProvider.getInstance().getSPI(EndpointMetricsFactory.class);
  endpoint.setEndpointMetrics(endpointMetricsFactory.newEndpointMetrics());
  registerEndpoint(endpoint);
  endpoint.getLifecycleHandler().start(endpoint);
  ServiceContainerEndpointRegistry.register(aliasName, endpoint);
  endpointConsumer.accept(endpoint);
}

代码示例来源：origin: org.jboss.eap/wildfly-webservices-server-integration

@Override
public void start(final StartContext context) throws StartException {
  WSLogger.ROOT_LOGGER.starting(name);
  final String domainName = (String)endpoint.getProperty(SECURITY_DOMAIN_NAME);
  if (isElytronSecurityDomain(endpoint, domainName)) {
    if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
      endpoint.setSecurityDomainContext(new ElytronSecurityDomainContextImpl(this.ejbApplicationSecurityDomainValue.getValue().getSecurityDomain()));
    } else {
      endpoint.setSecurityDomainContext(new ElytronSecurityDomainContextImpl(this.elytronSecurityDomain.getValue()));
    }
  } else {
    endpoint.setSecurityDomainContext(new SecurityDomainContextImpl(securityDomainContextValue.getValue()));
  }
  if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
    final EJBViewMethodSecurityAttributesService ejbMethodSecurityAttributeService = ejbMethodSecurityAttributeServiceValue.getValue();
    endpoint.addAttachment(EJBMethodSecurityAttributeProvider.class, new EJBMethodSecurityAttributesAdaptor(ejbMethodSecurityAttributeService));
  }
  final List<RecordProcessor> processors = endpoint.getRecordProcessors();
  for (final RecordProcessor processor : processors) {
    registerRecordProcessor(processor, endpoint);
  }
  final EndpointMetricsFactory factory = SPIProvider.getInstance().getSPI(EndpointMetricsFactory.class);
  endpoint.setEndpointMetrics(factory.newEndpointMetrics());
  registerEndpoint(endpoint);
  endpoint.getLifecycleHandler().start(endpoint);
}

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

Endpoint

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Endpoint类方法

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