Package org.jboss.wsf.spi.deployment

Examples of org.jboss.wsf.spi.deployment.Endpoint


               // set service name
               serviceMetaData.setServiceName(wsdlEndpoint.getWsdlService().getName());
               QName interfaceQName = wsdlEndpoint.getInterface().getName();

               Endpoint ep = dep.getService().getEndpointByName(linkName);
               ServerEndpointMetaData sepMetaData = new ServerEndpointMetaData(serviceMetaData, ep, portName, interfaceQName, Type.JAXRPC);
               sepMetaData.setPortComponentName(pcMetaData.getPortComponentName());
               sepMetaData.setLinkName(linkName);
               serviceMetaData.addEndpoint(sepMetaData);
View Full Code Here


      }
   }

   private BindingCustomization getCustomization()
   {
      Endpoint ep = EndpointAssociation.getEndpoint();
      return ep != null ? ep.getAttachment(BindingCustomization.class) : null;
   }
View Full Code Here

            String endpointAddress = null;
            try
            {
               SPIProvider spiProvider = SPIProviderResolver.getInstance().getProvider();
               EndpointRegistry epRegistry = spiProvider.getSPI(EndpointRegistryFactory.class).getEndpointRegistry();
               Endpoint endpoint = epRegistry.resolve( new PortComponentResolver(pcLink) );
               if (endpoint == null)
                  throw new WSException("Cannot resolve port-component-link: " + pcLink);

               ServerEndpointMetaData sepMetaData = endpoint.getAttachment(ServerEndpointMetaData.class);
               endpointAddress = sepMetaData.getEndpointAddress();
            }
            catch (Throwable ex)
            {
               // ignore, we are probably a remote client
View Full Code Here

   {
      String pcLink = req.getParameter("pcLink");
      if (pcLink == null)
         throw new IllegalArgumentException("Cannot obtain request parameter 'pcLink'");

      Endpoint endpoint = epRegistry.resolve( new PortComponentResolver(pcLink) );
      if (endpoint == null)
         throw new WSException("Cannot resolve port-component-link: " + pcLink);

      res.setContentType("text/plain");
      PrintWriter out = res.getWriter();

      ServerEndpointMetaData sepMetaData = endpoint.getAttachment(ServerEndpointMetaData.class);
      String endpointAddress = sepMetaData.getEndpointAddress();
      out.println(endpointAddress);

      log.debug("Resolved " + pcLink + " to: " + endpointAddress);
      out.close();
View Full Code Here

      this.pcLink = pcref;
   }

   public Endpoint query(Iterator<Endpoint> endpoints)
   {
      Endpoint endpoint = null;

      String pcName = this.pcLink;
      int hashIndex = this.pcLink.indexOf("#");
      if (hashIndex > 0)
      {
         pcName = pcLink.substring(hashIndex + 1);
      }

      while(endpoints.hasNext())
      {
         Endpoint auxEndpoint = endpoints.next();
         ServerEndpointMetaData sepMetaData = auxEndpoint.getAttachment(ServerEndpointMetaData.class);
         if (pcName.equals(sepMetaData.getPortComponentName()))
         {
            if (endpoint != null)
            {
               log.warn("Multiple service endoints found for: " + pcLink);
View Full Code Here

            String endpointAddress = null;
            try
            {
               SPIProvider spiProvider = SPIProviderResolver.getInstance().getProvider();
               EndpointRegistry epRegistry = spiProvider.getSPI(EndpointRegistryFactory.class).getEndpointRegistry();
               Endpoint endpoint = epRegistry.resolve( new PortComponentResolver(pcLink) );
               if (endpoint == null)
                  throw new WSException("Cannot resolve port-component-link: " + pcLink);

               ServerEndpointMetaData sepMetaData = endpoint.getAttachment(ServerEndpointMetaData.class);
               endpointAddress = sepMetaData.getEndpointAddress();
            }
            catch (Throwable ex)
            {
               // ignore, we are probably a remote client
View Full Code Here

   }

   // The destination jndiName is encoded in the service object name under key 'jms'
   private Endpoint getEndpointForDestination(EndpointRegistry epRegistry, String fromName)
   {
      Endpoint endpoint = null;
      for (ObjectName oname : epRegistry.getEndpoints())
      {
         Endpoint aux = epRegistry.getEndpoint(oname);
         String jmsProp = aux.getName().getKeyProperty("jms");
         if (jmsProp != null && jmsProp.equals(fromName))
         {
            endpoint = aux;
            break;
         }
View Full Code Here

      this.pcLink = pcref;
   }

   public Endpoint query(Iterator<Endpoint> endpoints)
   {
      Endpoint endpoint = null;

      String pcName = this.pcLink;
      int hashIndex = this.pcLink.indexOf("#");
      if (hashIndex > 0)
      {
         pcName = pcLink.substring(hashIndex + 1);
      }

      while(endpoints.hasNext())
      {
         Endpoint auxEndpoint = endpoints.next();
         ServerEndpointMetaData sepMetaData = auxEndpoint.getAttachment(ServerEndpointMetaData.class);
         if (pcName.equals(sepMetaData.getPortComponentName()))
         {
            if (endpoint != null)
            {
               log.warn("Multiple service endoints found for: " + pcLink);
View Full Code Here

   {
      String pcLink = req.getParameter("pcLink");
      if (pcLink == null)
         throw new IllegalArgumentException("Cannot obtain request parameter 'pcLink'");

      Endpoint endpoint = epRegistry.resolve( new PortComponentResolver(pcLink) );
      if (endpoint == null)
         throw new WSException("Cannot resolve port-component-link: " + pcLink);

      res.setContentType("text/plain");
      PrintWriter out = res.getWriter();

      ServerEndpointMetaData sepMetaData = endpoint.getAttachment(ServerEndpointMetaData.class);
      String endpointAddress = sepMetaData.getEndpointAddress();
      out.println(endpointAddress);

      log.debug("Resolved " + pcLink + " to: " + endpointAddress);
      out.close();
View Full Code Here

        if (endpointClass == null) {
            throw new NullPointerException("Null endpoint class");
        }

        final Endpoint endpoint = this.deploymentModelFactory.newHttpEndpoint(endpointClass);
        endpoint.setShortName(endpointName);
        dep.getService().addEndpoint(endpoint);

        return endpoint;
    }
View Full Code Here

TOP

Related Classes of org.jboss.wsf.spi.deployment.Endpoint

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.