import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
/**
 * Creates an OMBuilder for a plain XML message.
 *
 * @param inStream   InputStream for a XML message
 * @param charSetEnc Character set encoding to be used
 * @return Handler to a OMBuilder implementation instance
 * @throws javax.xml.stream.XMLStreamException
 */
public static StAXBuilder getBuilder(InputStream inStream, String charSetEnc) throws XMLStreamException {
    XMLStreamReader xmlReader = StAXUtils.createXMLStreamReader(inStream, charSetEnc);
    try {
        return new StAXSOAPModelBuilder(xmlReader);
    } catch (OMException e) {
        log.info("OMException in getSOAPBuilder", e);
        try {
            log.info("Remaining input stream :[" +
                    new String(IOUtils.getStreamAsByteArray(inStream), charSetEnc) + "]");
        } catch (IOException e1) {
            // Nothing here?
        }
        throw e;
    }
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
/**
 * Creates an OMBuilder for a SOAP message. Default character set encording is used.
 *
 * @param inStream InputStream for a SOAP message
 * @return Handler to a OMBuilder implementation instance
 * @throws javax.xml.stream.XMLStreamException
 */
public static StAXBuilder getSOAPBuilder(InputStream inStream) throws XMLStreamException {
    XMLStreamReader xmlReader = StAXUtils.createXMLStreamReader(inStream);
    try {
        return new StAXSOAPModelBuilder(xmlReader);
    } catch (OMException e) {
        log.info("OMException in getSOAPBuilder", e);
        try {
            log.info("Remaining input stream :[" +
                    new String(IOUtils.getStreamAsByteArray(inStream) , "UTF-8") + "]");
        } catch (IOException e1) {
            // Nothing here?
        }
        throw e;
    }
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
public void testEchoXMLSync() throws Exception {
    OMElement payload = createPayload();

    Options options = new Options();
    options.setTo(targetEPR);
    options.setTransportInProtocol(Constants.TRANSPORT_TCP);
    options.setAction(Constants.AXIS2_NAMESPACE_URI+"/"+operationName.getLocalPart());

    ServiceClient sender = new ServiceClient(configContext, clientService);
    sender.setOptions(options);
    OMElement result = sender.sendReceive(operationName, payload);

    result.serialize(StAXUtils.createXMLStreamWriter(
            System.out));
    sender.cleanup();
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
public void testEchoXMLCompleteSync() throws Exception {
    OMFactory fac = OMAbstractFactory.getOMFactory();

    OMNamespace omNs = fac.createOMNamespace("http://localhost/my", "my");
    OMElement payloadElement = fac.createOMElement("echoOMElement", omNs);
    OMElement value = fac.createOMElement("myValue", omNs);
    value.setText("Isaac Asimov, The Foundation Trilogy");
    payloadElement.addChild(value);

    Options options = new Options();
    options.setTo(targetEPR);
    options.setAction(Constants.AXIS2_NAMESPACE_URI+"/"+operationName.getLocalPart());
    options.setTransportInProtocol(Constants.TRANSPORT_TCP);
    options.setUseSeparateListener(true);

    ServiceClient sender = new ServiceClient(configContext, clientService);
    sender.setOptions(options);
    OMElement result = sender.sendReceive(operationName, payloadElement);

    result.serialize(StAXUtils.createXMLStreamWriter(
            System.out));
    sender.cleanup();

}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
/**
 * Util method to convert the pullstream to a string
 *
 * @param reader
 * @return
 */
private String getStringXML(XMLStreamReader reader) throws XMLStreamException {
    //the returned pullparser starts at an Element rather than the start
    //document event. This is somewhat disturbing but since an ADBBean
    //denotes an XMLFragment, it is justifiable to keep the current event
    //at the Start-element rather than the start document
    //What it boils down to is that we need to wrap the reader in a
    //stream wrapper to get a fake start-document event

    StreamingOMSerializer ser = new StreamingOMSerializer();
    ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
    XMLStreamWriter writer = StAXUtils.createXMLStreamWriter(byteArrayOutputStream);
    ser.serialize(
            new StreamWrapper(reader),
            writer);
    writer.flush();
    return byteArrayOutputStream.toString();
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
public void testStateMachine() throws Exception {
    String xmlDoc =
            "<wrapper><myIntVal>200</myIntVal><myIntVal>200</myIntVal><myIntVal>200</myIntVal>" +
                    "<myIntVal>200</myIntVal><myIntVal>200</myIntVal><myIntVal>200</myIntVal></wrapper>";
    XMLStreamReader reader = StAXUtils.createXMLStreamReader(
            new StringReader(xmlDoc));
    SimpleArrayReaderStateMachine sm = new SimpleArrayReaderStateMachine();
    sm.setElementNameToTest(new QName("myIntVal"));
    try {
        sm.read(reader);
    } catch (XMLStreamException e) {
        e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
    }

    assertEquals(6, sm.getTextArray().length);

}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
public void testStateMachineEmptyArray() throws Exception {
    String xmlDoc = "<wrapper></wrapper>";
    XMLStreamReader reader = StAXUtils.createXMLStreamReader(
            new StringReader(xmlDoc));
    SimpleArrayReaderStateMachine sm = new SimpleArrayReaderStateMachine();
    sm.setElementNameToTest(new QName("myIntVal"));
    try {
        sm.read(reader);
    } catch (Exception e) {

    }

    assertEquals(0, sm.getTextArray().length);


}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
protected Object[] getInputObject(List inputObjects, Operation operation)
        throws XMLStreamException, XmlSerializingException, XmlParsingException {
    StringWriter inputStringWriter = new StringWriter();
    XMLStreamWriter inputXmlStreamWriter = StAXUtils.createXMLStreamWriter(inputStringWriter);
    this.javaObjectSerializer.serializeInputElement(inputObjects.toArray(),
            operation.getInputElement(),
            operation.getInputParameters(),
            inputXmlStreamWriter);
    inputXmlStreamWriter.flush();
    String inputXmlString = inputStringWriter.toString();

    System.out.println("input Xml String ==> " + inputXmlString);

    XMLStreamReader xmlReader = StAXUtils.createXMLStreamReader(new ByteArrayInputStream(inputXmlString.getBytes()));
    Object[] objects = this.xmlStreamParser.getInputParameters(xmlReader, operation);
    return objects;
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
protected Object getReturnObject(Object returnObject, Operation operation)
        throws XMLStreamException, XmlSerializingException, XmlParsingException {
    // get the response xml serializer
    StringWriter outputStringWriter = new StringWriter();
    XMLStreamWriter outputXMLStringWriter = StAXUtils.createXMLStreamWriter(outputStringWriter);

    this.javaObjectSerializer.serializeOutputElement(returnObject,
            operation.getOutPutElement(),
            operation.getOutputParameter(),
            outputXMLStringWriter);
    outputXMLStringWriter.flush();
    String outputXmlString = outputStringWriter.toString();
    System.out.println("output Xml String ==> " + outputXmlString);

    XMLStreamReader outputXmlReader =
            StAXUtils.createXMLStreamReader(new ByteArrayInputStream(outputXmlString.getBytes()));

    return this.xmlStreamParser.getOutputObject(outputXmlReader, operation);
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
@Override
protected XMLStreamReader _getReaderFromBO(Object busObj, Object busContext)
        throws XMLStreamException, WebServiceException {
    try {
        if (busObj instanceof DataSource) {
            XMLInputFactory f = StAXUtils.getXMLInputFactory();

            XMLStreamReader reader = f.createXMLStreamReader(((DataSource)busObj).getInputStream());
            StAXUtils.releaseXMLInputFactory(f);
            return reader;
        }
        throw ExceptionFactory.makeWebServiceException(
                Messages.getMessage("SourceNotSupported", busObject.getClass().getName()));
    } catch (Exception e) {
        String className = (busObj == null) ? "none" : busObj.getClass().getName();
        throw ExceptionFactory
                .makeWebServiceException(Messages.getMessage("SourceReadErr", className), e);
    }
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
/** Creates an XMLStreamReader from a Source using a slow but proven algorithm. */
private XMLStreamReader _slow_getReaderFromSource(Source src) throws XMLStreamException {
    if (log.isDebugEnabled()) {
        log.debug("Start _slow_getReaderFromSource");
    }
    byte[] bytes = (byte[]) ConvertUtils.convert(src, byte[].class);
    if (log.isDebugEnabled()) {
        log.debug("Successfully converted to ByteArray");
    }
    ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
    XMLStreamReader reader = StAXUtils.createXMLStreamReader(bais);
    if (log.isDebugEnabled()) {
        log.debug("End _slow_getReaderFromSource =" + reader);
    }
    return reader;
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
private org.apache.axiom.soap.SOAPEnvelope toOM(String xml)
        throws WebServiceException {
	if (log.isDebugEnabled()) {
	    log.debug("Converting SAAJ SOAPEnvelope String to an OM SOAPEnvelope");
	    log.debug("The conversion occurs due to " + JavaUtils.stackToString());
	} 
	
    XMLStreamReader reader;
    try {
        reader = StAXUtils.createXMLStreamReader(new ByteArrayInputStream(xml.getBytes()));
    } catch (XMLStreamException e) {
        throw ExceptionFactory.makeWebServiceException(e);
    }
    // Get a SOAP OM Builder.  Passing null causes the version to be automatically triggered
    StAXSOAPModelBuilder builder = new StAXSOAPModelBuilder(reader, null);
    // Create and return the OM Envelope
    return builder.getSOAPEnvelope();
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
/**
 * Called if we have passed the pivot point but someone wants to output the block. The actual
 * block implementation may choose to override this setting.
 */
protected XMLStreamReader _postPivot_getXMLStreamReader()
        throws XMLStreamException, WebServiceException {
    if (log.isDebugEnabled()) {
        QName theQName = isQNameAvailable() ? getQName() : new QName("unknown");
        log.debug("The Block for " + theQName +
                " is already consumed and therefore it is only partially read.");
        log.debug("If you need this block preserved, please set the " + Constants
                .SAVE_REQUEST_MSG + " property on the MessageContext.");
    }
    QName qName = getQName();
    String text = "";
    if (qName.getNamespaceURI().length() > 0) {
        text = "<prefix:" + qName.getLocalPart() + " xmlns:prefix='" + qName.getNamespaceURI() +
                "'/>";
    } else {
        text = "<" + qName.getLocalPart() + "/>";
    }
    StringReader sr = new StringReader(text);
    return StAXUtils.createXMLStreamReader(sr);
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
/**
 * Creates an OMBuilder for a plain XML message.
 *
 * @param inStream   InputStream for a XML message
 * @param charSetEnc Character set encoding to be used
 * @return Handler to a OMBuilder implementation instance
 * @throws XMLStreamException
 */
public static StAXBuilder getBuilder(InputStream inStream, String charSetEnc)
        throws XMLStreamException {
    XMLStreamReader xmlReader = StAXUtils.createXMLStreamReader(inStream, charSetEnc);
    try {
        return new StAXSOAPModelBuilder(xmlReader);
    } catch (OMException e) {
        log.info("OMException in getSOAPBuilder", e);
        try {
            log.info("Remaining input stream :[" +
                     new String(IOUtils.getStreamAsByteArray(inStream), charSetEnc) + "]");
        } catch (IOException e1) {
            // Nothing here?
        }
        throw e;
    }
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
/**
 * Creates an OMBuilder for a SOAP message. Default character set encording is used.
 *
 * @param inStream InputStream for a SOAP message
 * @return Handler to a OMBuilder implementation instance
 * @throws XMLStreamException
 */
public static StAXBuilder getSOAPBuilder(InputStream inStream) throws XMLStreamException {
    XMLStreamReader xmlReader = StAXUtils.createXMLStreamReader(inStream);
    try {
        return new StAXSOAPModelBuilder(xmlReader);
    } catch (OMException e) {
        log.info("OMException in getSOAPBuilder", e);
        try {
            log.info("Remaining input stream :[" +
                     new String(IOUtils.getStreamAsByteArray(inStream)) + "]");
        } catch (IOException e1) {
            // Nothing here?
        }
        throw e;
    }
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
public void startUp(ConfigurationContext configctx,
                    AxisService service) {
    try {
        String tempDir = System.getProperty("java.io.tmpdir");
        File tempFile = new File(tempDir);
        File libFile = new File(tempFile, "library.xml");
        OMElement libraryElement;
        boolean noFile = true;
        if (!libFile.exists()) {
            //Service starting at the first time or user has clean the temp.dir
            Parameter allBooks = service.getParameter(LibraryConstants.ALL_BOOK);
            libraryElement = allBooks.getParameterElement();
        } else {
            InputStream in = new FileInputStream(libFile);
            XMLStreamReader xmlReader = StAXUtils
                    .createXMLStreamReader(in);
            StAXOMBuilder staxOMBuilder = new StAXOMBuilder(xmlReader);
            libraryElement = staxOMBuilder.getDocumentElement();
            noFile = false;
        }
        processOmelemnt(libraryElement, service, noFile);
    } catch (Exception exception) {
        log.info(exception);
    }
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
public void testPopulate() throws Exception{

            XMLStreamReader reader = StAXUtils.createXMLStreamReader(new ByteArrayInputStream(xmlString.getBytes()));
            Class clazz = Class.forName("org.soapinterop.xsd.Myobject");
            Class innerClazz = Util.getFactory(clazz);
            Method parseMethod = innerClazz.getMethod("parse",new Class[]{XMLStreamReader.class});
            Object obj = parseMethod.invoke(null,new Object[]{reader});


            Object myObject = null ;
            BeanInfo beanInfo =  Introspector.getBeanInfo(obj.getClass());
            PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
            for (int i = 0; i < propertyDescriptors.length; i++) {
                PropertyDescriptor propertyDescriptor = propertyDescriptors[i];
                if ("myobject".equals(propertyDescriptor.getDisplayName())){
                    Method readMethod = propertyDescriptor.getReadMethod();
                    myObject = readMethod.invoke(obj,new Object[]{});
                    break;
                }


            }

            assertNotNull(myObject);
    }
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
private static void testSerializeDeserializeUsingMTOMWithoutOptimize(Object bean, Object expectedResult) throws Exception {
        SOAPEnvelope envelope = OMAbstractFactory.getSOAP11Factory().getDefaultEnvelope();
        envelope.getBody().addChild(ADBBeanUtil.getOMElement(bean));
        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        OMOutputFormat format = new OMOutputFormat();
        MultipartWriter mpWriter = JavaMailMultipartWriterFactory.INSTANCE.createMultipartWriter(buffer, format.getMimeBoundary());
        OutputStream rootPartWriter = mpWriter.writePart("application/xop+xml; charset=UTF-8; type=\"text/xml\"", "binary", format.getRootContentId());
        envelope.serialize(rootPartWriter, format);
        rootPartWriter.close();
        mpWriter.complete();
//        System.out.write(buffer.toByteArray());
        String contentType = format.getContentTypeForMTOM("text/xml");
        Attachments attachments = new Attachments(new ByteArrayInputStream(buffer.toByteArray()), contentType);
        MTOMStAXSOAPModelBuilder builder = new MTOMStAXSOAPModelBuilder(StAXUtils.createXMLStreamReader(attachments.getSOAPPartInputStream()), attachments);
        OMElement bodyElement = builder.getSOAPEnvelope().getBody().getFirstElement();
        assertBeanEquals(expectedResult, ADBBeanUtil.parse(bean.getClass(), bodyElement.getXMLStreamReaderWithoutCaching()));
    }
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
private static OMElement buildOMElement() {
    String xmlString = "<ns1:Project xmlns:ns1=\"http://axis2.apache.org/sample\">\n" +
            "    <ns1:Developer>\n" +
            "        <ns1:name>AAA</ns1:name>\n" +
            "        <ns1:location>Colombo</ns1:location>\n" +
            "    </ns1:Developer>\n" +
            "</ns1:Project>";
    OMElement omElement = null;
    try {
        XMLStreamReader xmlStreamReader =
                StAXUtils.createXMLStreamReader(new ByteArrayInputStream(xmlString.getBytes()));
        StAXOMBuilder stAXOMBuilder = new StAXOMBuilder(xmlStreamReader);
        omElement = stAXOMBuilder.getDocumentElement();
    } catch (XMLStreamException e) {
        e.printStackTrace();
    }
    return omElement;
}
 

import org.apache.axiom.om.util.StAXUtils; //导入依赖的package包/类
private static SOAPEnvelope buildSoapEnvelope() {

        String xmlString = "<soapenv:Envelope xmlns:soapenv=\"http://www.w3.org/2003/05/soap-envelope\">\n" +
                "    <soapenv:Body>\n" +
                "        <ns1:Project xmlns:ns1=\"http://axis2.apache.org/sample\">\n" +
                "            <ns1:Developer>\n" +
                "                <ns1:name>AAA</ns1:name>\n" +
                "                <ns1:location>Colombo</ns1:location>\n" +
                "            </ns1:Developer>\n" +
                "        </ns1:Project>\n" +
                "    </soapenv:Body>\n" +
                "</soapenv:Envelope>";

        SOAPEnvelope soapEnvelope = null;
        try {
            XMLStreamReader xmlStreamReader =
                    StAXUtils.createXMLStreamReader(new ByteArrayInputStream(xmlString.getBytes()));
            StAXSOAPModelBuilder stAXSOAPModelBuilder = new StAXSOAPModelBuilder(xmlStreamReader);
            soapEnvelope = stAXSOAPModelBuilder.getSOAPEnvelope();
        } catch (XMLStreamException e) {
            e.printStackTrace();
        }
        return soapEnvelope;
    }