javaserviceimplwriter.java

Java有关XML编程需要用到axis 的源代码 把里面bin下的包导入相应的Java工程 进行使用

    }    // writeAddressInfo

    /**
     * Write the private WSDD service name field and the public accessors for it.
     * 
     * @param pw              
     * @param wsddServiceName 
     * @param portName        
     */
    protected void writeWSDDServiceNameInfo(PrintWriter pw,
                                            String wsddServiceName,
                                            String portName, String portXmlName) {

        // Write the private WSDD service name field
        pw.println("    // " + Messages.getMessage("wsddServiceName00"));
        pw.println("    private java.lang.String " + wsddServiceName + " = \""
                + portXmlName + "\";");        
        pw.println();

        // Write the public accessors for the WSDD service name
        pw.println("    public java.lang.String get" + wsddServiceName
                + "() {");
        pw.println("        return " + wsddServiceName + ";");
        pw.println("    }");
        pw.println();
        pw.println("    public void set" + wsddServiceName
                + "(java.lang.String name) {");
        pw.println("        " + wsddServiceName + " = name;");
        pw.println("    }");
        pw.println();
    }    // writeWSDDServiceNameInfo

    /**
     * Write the get<portName>() method.
     * 
     * @param pw          
     * @param bindingType 
     * @param portName    
     */
    protected void writeGetPortName(PrintWriter pw, String bindingType,
                                    String portName) {

        pw.println("    public " + bindingType + " get" + portName
                + "() throws "
                + javax.xml.rpc.ServiceException.class.getName() + " {");
        pw.println("       java.net.URL endpoint;");
        pw.println("        try {");
        pw.println("            endpoint = new java.net.URL(" + portName
                + "_address);");
        pw.println("        }");
        pw.println("        catch (java.net.MalformedURLException e) {");
        pw.println("            throw new javax.xml.rpc.ServiceException(e);");
        pw.println("        }");
        pw.println("        return get" + portName + "(endpoint);");
        pw.println("    }");
        pw.println();
    }    // writeGetPortName

    /**
     * Write the get<portName>(URL) method.
     * 
     * @param pw              
     * @param bindingType     
     * @param portName        
     * @param stubClass       
     * @param wsddServiceName 
     */
    protected void writeGetPortNameURL(PrintWriter pw, String bindingType,
                                       String portName, String stubClass,
                                       String wsddServiceName) {

        pw.println("    public " + bindingType + " get" + portName
                + "(java.net.URL portAddress) throws "
                + javax.xml.rpc.ServiceException.class.getName() + " {");
        pw.println("        try {");
        pw.println("            " + stubClass + " _stub = new " + stubClass
                + "(portAddress, this);");
        pw.println("            _stub.setPortName(get" + wsddServiceName
                + "());");
        pw.println("            return _stub;");
        pw.println("        }");
        pw.println("        catch (org.apache.axis.AxisFault e) {");
        pw.println("            return null;");
        pw.println("        }");
        pw.println("    }");
        pw.println();
    }    // writeGetPortNameURL

    /**
     * Write the set<portName>EndpointAddress(String) method.
     * 
     * @param pw       
     * @param portName 
     */
    protected void writeSetPortEndpointAddress(PrintWriter pw,
                                               String portName) {

        pw.println("    public void set" + portName
                + "EndpointAddress(java.lang.String address) {");
        pw.println("        " + portName + "_address = address;");
        pw.println("    }");
        pw.println();
    }    // writeSetPortEndpointAddress

    /**
     * Write the getPort(Class serviceInterfaceWriter) method.
     * 
     * @param pw                 
     * @param getPortIfaces      
     * @param getPortStubClasses 
     * @param getPortPortNames   
     * @param printGetPortNotice 
     */
    protected void writeGetPortClass(PrintWriter pw, Vector getPortIfaces,
                                     Vector getPortStubClasses,
                                     Vector getPortPortNames,
                                     boolean printGetPortNotice) {

        pw.println("    /**");
        pw.println("     * " + Messages.getMessage("getPortDoc00"));
        pw.println("     * " + Messages.getMessage("getPortDoc01"));
        pw.println("     * " + Messages.getMessage("getPortDoc02"));

        if (printGetPortNotice) {
            pw.println("     * " + Messages.getMessage("getPortDoc03"));
            pw.println("     * " + Messages.getMessage("getPortDoc04"));
        }

        pw.println("     */");
        pw.println(
                "    public java.rmi.Remote getPort(Class serviceEndpointInterface) throws "
                + javax.xml.rpc.ServiceException.class.getName() + " {");

        if (getPortIfaces.size() == 0) {
            pw.println(
                    "        throw new "
                    + javax.xml.rpc.ServiceException.class.getName() + "(\""
                    + Messages.getMessage("noStub")
                    + "  \" + (serviceEndpointInterface == null ? \"null\" : serviceEndpointInterface.getName()));");
        } else {
            pw.println("        try {");

            for (int i = 0; i < getPortIfaces.size(); ++i) {
                String iface = (String) getPortIfaces.get(i);
                String stubClass = (String) getPortStubClasses.get(i);
                String portName = (String) getPortPortNames.get(i);

                pw.println(
                        "            if (" + iface
                        + ".class.isAssignableFrom(serviceEndpointInterface)) {");
                pw.println("                " + stubClass + " _stub = new "
                        + stubClass + "(new java.net.URL(" + portName
                        + "_address), this);");
                pw.println("                _stub.setPortName(get" + portName
                        + "WSDDServiceName());");
                pw.println("                return _stub;");
                pw.println("            }");
            }

            pw.println("        }");
            pw.println("        catch (java.lang.Throwable t) {");
            pw.println("            throw new "
                    + javax.xml.rpc.ServiceException.class.getName()
                    + "(t);");
            pw.println("        }");
            pw.println(
                    "        throw new "
                    + javax.xml.rpc.ServiceException.class.getName() + "(\""
                    + Messages.getMessage("noStub")
                    + "  \" + (serviceEndpointInterface == null ? \"null\" : serviceEndpointInterface.getName()));");
        }

        pw.println("    }");
        pw.println();
    }    // writeGetPortClass

    /**
     * Write the getPort(QName portName, Class serviceInterfaceWriter) method.
     * 
     * @param pw               
     * @param getPortPortNames 
     */
    protected void writeGetPortQNameClass(PrintWriter pw,
                                          Vector getPortPortNames,
            Vector getPortPortXmlNames) {

        pw.println("    /**");
        pw.println("     * " + Messages.getMessage("getPortDoc00"));
        pw.println("     * " + Messages.getMessage("getPortDoc01"));
        pw.println("     * " + Messages.getMessage("getPortDoc02"));
        pw.println("     */");
        pw.println(
                "    public java.rmi.Remote getPort(javax.xml.namespace.QName portName, Class serviceEndpointInterface) throws "
                + javax.xml.rpc.ServiceException.class.getName() + " {");
        pw.println("        if (portName == null) {");
        pw.println("            return getPort(serviceEndpointInterface);");
        pw.println("        }");
        pw.println("        java.lang.String inputPortName = portName.getLocalPart();");
        pw.print("        ");

        for (int i = 0; i < getPortPortNames.size(); ++i) {
            String portName = (String) getPortPortNames.get(i);
            String portXmlName = (String) getPortPortXmlNames.get(i);

            pw.println("if (\"" + portXmlName + "\".equals(inputPortName)) {");
            pw.println("            return get" + portName + "();");
            pw.println("        }");
            pw.print("        else ");
        }

        pw.println(" {");
        pw.println(
                "            java.rmi.Remote _stub = getPort(serviceEndpointInterface);");
        pw.println(
                "            ((org.apache.axis.client.Stub) _stub).setPortName(portName);");
        pw.println("            return _stub;");
        pw.println("        }");
        pw.println("    }");
        pw.println();
    }    // writeGetPortQNameClass

    /**
     * Write the getServiceName method.
     * 
     * @param pw    
     * @param qname 
     */

   protected void writeGetServiceName(PrintWriter pw, QName qname) {
    	String originalServiceName = null;
    	QName qNameWithDifferentLocal = null;
    	QName qNameWithBackslashedLocal = null;
    	
    	originalServiceName = sEntry.getOriginalServiceName();
    	qNameWithDifferentLocal = BackslashUtil.getQNameWithDifferentLocal(qname, originalServiceName);
    	qNameWithBackslashedLocal = BackslashUtil.getQNameWithBackslashedLocal(qNameWithDifferentLocal);
    	
        pw.println("    public javax.xml.namespace.QName getServiceName() {");
        
        pw.println("        return " +  Utils.getNewQName(qNameWithBackslashedLocal) + ";");
        pw.println("    }");
        pw.println();
    }    // writeGetServiceName    

    /**
     * Write the getPorts method.
     * 
     * @param pw        
     * @param portNames 
     */
    protected void writeGetPorts(PrintWriter pw, String namespaceURI, Vector portNames) {

        pw.println("    private java.util.HashSet ports = null;");
        pw.println();
        pw.println("    public java.util.Iterator getPorts() {");
        pw.println("        if (ports == null) {");
        pw.println("            ports = new java.util.HashSet();");

        for (int i = 0; i < portNames.size(); ++i) {
            pw.println("            ports.add(new javax.xml.namespace.QName(\"" + 
                    namespaceURI + "\", \"" + portNames.get(i) + "\"));");
        }

        pw.println("        }");
        pw.println("        return ports.iterator();");
        pw.println("    }");
        pw.println();
    }    // writeGetPorts

    /**
     * Write the setEndpointAddress(String portName, String newAddress)
     * and setEndpointAddress(QName portName, String newAddress) methods.
     * 
     * @param pw        
     * @param portNames 
     */
    protected void writeSetEndpointAddress(PrintWriter pw, Vector portNames) {

        if (portNames.isEmpty()) {
            return;
        }

        // String method
        pw.println("    /**");
        pw.println("    * " + Messages.getMessage("setEndpointDoc00"));
        pw.println("    */");
        pw.println(
                "    public void setEndpointAddress(java.lang.String portName, java.lang.String address) throws "
                + javax.xml.rpc.ServiceException.class.getName() + " {");

        pw.println("        ");
        for (Iterator p = portNames.iterator(); p.hasNext();) {
            String name = (String) p.next();

            pw.println("if (\"" + name + "\".equals(portName)) {");
            pw.println("            set" + name + "EndpointAddress(address);");
            pw.println("        }");
            pw.println("        else ");
        }

        pw.println("{ // Unknown Port Name");
        pw.println("            throw new "
                + javax.xml.rpc.ServiceException.class.getName() + "(\" "
                + Messages.getMessage("unknownPortName")
                + "\" + portName);");
        pw.println("        }");
        pw.println("    }");
        pw.println();

        // QName method
        pw.println("    /**");
        pw.println("    * " + Messages.getMessage("setEndpointDoc00"));
        pw.println("    */");
        pw.println(
                "    public void setEndpointAddress(javax.xml.namespace.QName portName, java.lang.String address) throws "
                + javax.xml.rpc.ServiceException.class.getName() + " {");
        pw.println(
                "        setEndpointAddress(portName.getLocalPart(), address);");
        pw.println("    }");
        pw.println();
    }    // writeSetEndpointAddress
}    // class JavaServiceImplWriter