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

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

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

Endpoint.getType介绍

[英]Get endpoint type
[中]获取端点类型

代码示例

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

/**
* Returns true if endpoint represents JAXWS JSE endpoint.
*
* @param ep webservice endpoint
* @return true if either JAXWS JSE endpoint, false otherwise
*/
public static boolean isJaxwsJseEndpoint( final Endpoint ep )
{
 return JAXWS_JSE == ep.getType();
}

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

/**
* Returns true if endpoint represents JAXWS EJB3 endpoint.
*
* @param ep webservice endpoint
* @return true if JAXWS EJB3 endpoint, false otherwise
*/
public static boolean isJaxwsEjbEndpoint( final Endpoint ep )
{
 return JAXWS_EJB3 == ep.getType();
}

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

@Override
public List<Endpoint> getEndpoints(final EndpointTypeFilter filter)
{
 List<Endpoint> result = new LinkedList<Endpoint>();
 for (Endpoint endpoint : endpoints)
 {
   if (filter.accept(endpoint.getType()))
   {
    result.add(endpoint);
   }
 }
 return Collections.unmodifiableList(result);
}

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

@Override
public void start(final Deployment dep) {
  final DeploymentUnit unit = dep.getAttachment(DeploymentUnit.class);
  if (unit instanceof WSEndpointDeploymentUnit) return;
  for (final Endpoint endpoint : dep.getService().getEndpoints()) {
    ModelNode op = null;
    try {
      op = unit.createDeploymentSubModel(WSExtension.SUBSYSTEM_NAME,
          PathElement.pathElement(ENDPOINT, URLEncoder.encode(getId(endpoint), "UTF-8")));
    } catch (final UnsupportedEncodingException e) {
      throw new RuntimeException(e);
    }
    op.get(ENDPOINT_NAME).set(getName(endpoint));
    op.get(ENDPOINT_CONTEXT).set(getContext(endpoint));
    op.get(ENDPOINT_CLASS).set(endpoint.getTargetBeanName());
    op.get(ENDPOINT_TYPE).set(endpoint.getType().toString());
    op.get(ENDPOINT_WSDL).set(endpoint.getAddress() + "?wsdl");
  }
}

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

@Override
public void start(final Deployment dep) {
  final DeploymentUnit unit = dep.getAttachment(DeploymentUnit.class);
  if (unit instanceof WSEndpointDeploymentUnit) return;
  final DeploymentResourceSupport deploymentResourceSupport = unit.getAttachment(Attachments.DEPLOYMENT_RESOURCE_SUPPORT);
  for (final Endpoint endpoint : dep.getService().getEndpoints()) {
    final ModelNode endpointModel;
    try {
      endpointModel = deploymentResourceSupport.getDeploymentSubModel(WSExtension.SUBSYSTEM_NAME,
          PathElement.pathElement(ENDPOINT, URLEncoder.encode(getId(endpoint), "UTF-8")));
    } catch (final UnsupportedEncodingException e) {
      throw new RuntimeException(e);
    }
    endpointModel.get(ENDPOINT_NAME).set(getName(endpoint));
    endpointModel.get(ENDPOINT_CONTEXT).set(getContext(endpoint));
    endpointModel.get(ENDPOINT_CLASS).set(endpoint.getTargetBeanName());
    endpointModel.get(ENDPOINT_TYPE).set(endpoint.getType().toString());
    endpointModel.get(ENDPOINT_WSDL).set(endpoint.getAddress() + "?wsdl");
  }
}

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

@Override
public void start(final Deployment dep) {
  final DeploymentUnit unit = dep.getAttachment(DeploymentUnit.class);
  if (unit instanceof WSEndpointDeploymentUnit) return;
  final DeploymentResourceSupport deploymentResourceSupport = unit.getAttachment(Attachments.DEPLOYMENT_RESOURCE_SUPPORT);
  for (final Endpoint endpoint : dep.getService().getEndpoints()) {
    final ModelNode endpointModel;
    try {
      endpointModel = deploymentResourceSupport.getDeploymentSubModel(WSExtension.SUBSYSTEM_NAME,
          PathElement.pathElement(ENDPOINT, URLEncoder.encode(getId(endpoint), "UTF-8")));
    } catch (final UnsupportedEncodingException e) {
      throw new RuntimeException(e);
    }
    endpointModel.get(ENDPOINT_NAME).set(getName(endpoint));
    endpointModel.get(ENDPOINT_CONTEXT).set(getContext(endpoint));
    endpointModel.get(ENDPOINT_CLASS).set(endpoint.getTargetBeanName());
    endpointModel.get(ENDPOINT_TYPE).set(endpoint.getType().toString());
    endpointModel.get(ENDPOINT_WSDL).set(endpoint.getAddress() + "?wsdl");
  }
}

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

private InvocationHandler getInvocationHandler(final Endpoint ep)
{
 final InvocationType invocationType = InvocationType.valueOf(ep.getType().toString());
 return spiProvider.getSPI(InvocationHandlerFactory.class).newInvocationHandler(invocationType);
}

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

private static boolean isElytronSecurityDomain(Endpoint endpoint, String domainName) {
  final ServiceName serviceName;
  if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
    serviceName = APPLICATION_SECURITY_DOMAIN_RUNTIME_CAPABILITY.getCapabilityServiceName(domainName, ApplicationSecurityDomainService.ApplicationSecurityDomain.class);
  } else {
    serviceName = ELYTRON_DOMAIN_CAPABILITY.getCapabilityServiceName(domainName, SecurityDomain.class);
  }
  return currentServiceContainer().getService(serviceName) != null;
}

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

private static boolean isElytronSecurityDomain(Endpoint endpoint, String domainName) {
  final ServiceName serviceName;
  if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
    serviceName = APPLICATION_SECURITY_DOMAIN_RUNTIME_CAPABILITY.getCapabilityServiceName(domainName, ApplicationSecurityDomainService.ApplicationSecurityDomain.class);
  } else {
    serviceName = ELYTRON_DOMAIN_CAPABILITY.getCapabilityServiceName(domainName, SecurityDomain.class);
  }
  return currentServiceContainer().getService(serviceName) != null;
}

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

endpoint.setProperty(SECURITY_DOMAIN_NAME, domainName);
if (isElytronSecurityDomain(endpoint, domainName)) {
  if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
    ServiceName ejbSecurityDomainServiceName = APPLICATION_SECURITY_DOMAIN_RUNTIME_CAPABILITY
        .getCapabilityServiceName(domainName, ApplicationSecurityDomainService.ApplicationSecurityDomain.class);
if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
  builder.addDependency(getEJBViewMethodSecurityAttributesServiceName(unit, endpoint),
      EJBViewMethodSecurityAttributesService.class, service.getEJBMethodSecurityAttributeServiceInjector());

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

endpoint.setProperty(SECURITY_DOMAIN_NAME, domainName);
if (isElytronSecurityDomain(endpoint, domainName)) {
  if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
    ServiceName ejbSecurityDomainServiceName = APPLICATION_SECURITY_DOMAIN_RUNTIME_CAPABILITY
        .getCapabilityServiceName(domainName, ApplicationSecurityDomainService.ApplicationSecurityDomain.class);
if (EndpointType.JAXWS_EJB3.equals(endpoint.getType())) {
  ejbMethodSecurityAttributeService = builder.requires(getEJBViewMethodSecurityAttributesServiceName(unit, endpoint));

代码示例来源: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);
}

相关文章