Package com.sun.xml.rpc.spi.runtime

Examples of com.sun.xml.rpc.spi.runtime.Implementor


        rpcFactory_ = JaxRpcObjectFactory.newInstance();
    }

    public Implementor getImplementorFor(RuntimeEndpointInfo targetEndpoint) {

        Implementor implementor = null;
        try {
            synchronized(targetEndpoint) {
                implementor = (Implementor)
                    implementorCache_.get(targetEndpoint);
                if( implementor == null ) {
                    implementor = createImplementor(targetEndpoint);
                    implementorCache_.put(targetEndpoint, implementor);
                }
            }

            InvocationManager invManager =
                Switch.getSwitch().getInvocationManager();
            ComponentInvocation inv = invManager.getCurrentInvocation();
            inv.setWebServiceTie(implementor.getTie());

        } catch(Throwable t) {
/* XXX FIXME
            JAXRPCServletException jse = new JAXRPCServletException
                ("error.implementorFactory.newInstanceFailed",
View Full Code Here


    }

    public void destroy() {
        for (Iterator iter = implementorCache_.values().iterator();
             iter.hasNext();) {
            Implementor implementor = (Implementor) iter.next();
            try {
                implementor.destroy();
            } catch(Throwable t) {
                // @@@ log
            }
        }
        implementorCache_.clear();
View Full Code Here

            servant = (Remote) Proxy.newProxyInstance
                (implClass.getClassLoader(), proxyInterfaces, handler);
        }
        tie.setTarget(servant);
       
        Implementor implementor = rpcFactory_.createImplementor(servletContext_, tie);
        implementor.init();

        return implementor;
    }
View Full Code Here

  if(_logger.isLoggable(Level.FINE)){
      _logger.fine("ws.processRequest");
  }

        final SOAPMessageContext finalMC = messageContext;
  Implementor implementor = (Implementor) messageContext.getProperty( IMPLEMENTOR );
        final Tie tie = implementor.getTie();
  StreamingHandler handler = (StreamingHandler) implementor.getTie();
  SOAPMessage request = finalMC.getMessage();
  final ServerAuthContext sAC = config_.getAuthContext(handler,request);

        boolean status = true;
  try {
View Full Code Here

  if(_logger.isLoggable(Level.FINE)){
      _logger.fine("ws.processRequest");
  }

        final SOAPMessageContext finalMC = messageContext;
  Implementor implementor = (Implementor) messageContext.getProperty( IMPLEMENTOR );
        final Tie tie = implementor.getTie();
  StreamingHandler handler = (StreamingHandler) implementor.getTie();
  SOAPMessage request = finalMC.getMessage();
  final ServerAuthContext sAC = config_.getAuthContext(handler,request);

        boolean status = true;
  try {
View Full Code Here

        rpcFactory_ = JaxRpcObjectFactory.newInstance();
    }

    public Implementor getImplementorFor(RuntimeEndpointInfo targetEndpoint) {

        Implementor implementor = null;
        try {
            synchronized(targetEndpoint) {
                implementor = (Implementor)
                    implementorCache_.get(targetEndpoint);
                if( implementor == null ) {
                    implementor = createImplementor(targetEndpoint);
                    implementorCache_.put(targetEndpoint, implementor);
                }
            }

            WebServiceContractImpl wscImpl = WebServiceContractImpl.getInstance();
            InvocationManager invManager = wscImpl.getInvocationManager();
            ComponentInvocation inv = invManager.getCurrentInvocation();
            if (inv instanceof EJBInvocation)
                ((EJBInvocation)inv).setWebServiceTie(implementor.getTie());
        } catch(Throwable t) {
            RuntimeException re = new RuntimeException();
            re.initCause(t);
            throw re;
        }
View Full Code Here

    }

    public void destroy() {
        for (Iterator iter = implementorCache_.values().iterator();
             iter.hasNext();) {
            Implementor implementor = (Implementor) iter.next();
            try {
                implementor.destroy();
            } catch(Throwable t) {
                // @@@ log
            }
        }
        implementorCache_.clear();
View Full Code Here

            servant = (Remote) Proxy.newProxyInstance
                (implClass.getClassLoader(), proxyInterfaces, handler);
        }
        tie.setTarget(servant);
       
        Implementor implementor = rpcFactory_.createImplementor(servletContext_, tie);
        implementor.init();

        return implementor;
    }
View Full Code Here

  if(_logger.isLoggable(Level.FINE)){
      _logger.fine("ws.processRequest");
  }

        final SOAPMessageContext finalMC = messageContext;
  Implementor implementor = (Implementor) messageContext.getProperty( IMPLEMENTOR );
        final Tie tie = implementor.getTie();
  StreamingHandler handler = (StreamingHandler) implementor.getTie();
  SOAPMessage request = finalMC.getMessage();
  final ServerAuthContext sAC = config_.getAuthContext(handler,request);

        boolean status = true;
  try {
View Full Code Here

TOP

Related Classes of com.sun.xml.rpc.spi.runtime.Implementor

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.