Update the JMS binding so that the message format may be either AXIOM or DOM. The default is still DOM as that minimizes the required dependencies but you can now configure it to use AXIOM OMElements which are optimized in some runtime environments

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1199797 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 102 insertions, 0 deletions

diff --git a/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/xml/AXIOMXMLHelper.java b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/xml/AXIOMXMLHelper.java
new file mode 100644
index 0000000000..bdf2deb5a5
--- /dev/null
+++ b/sca-java-2.x/trunk/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/xml/AXIOMXMLHelper.java
@@ -0,0 +1,102 @@
+/*

+ * Licensed to the Apache Software Foundation (ASF) under one

+ * or more contributor license agreements.  See the NOTICE file

+ * distributed with this work for additional information

+ * regarding copyright ownership.  The ASF licenses this file

+ * to you under the Apache License, Version 2.0 (the

+ * "License"); you may not use this file except in compliance

+ * with the License.  You may obtain a copy of the License at

+ * 

+ *   http://www.apache.org/licenses/LICENSE-2.0

+ * 

+ * Unless required by applicable law or agreed to in writing,

+ * software distributed under the License is distributed on an

+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

+ * KIND, either express or implied.  See the License for the

+ * specific language governing permissions and limitations

+ * under the License.    

+ */

+

+package org.apache.tuscany.sca.binding.jms.provider.xml;

+

+import java.io.IOException;

+

+import javax.xml.namespace.QName;

+import javax.xml.stream.XMLStreamException;

+

+import org.apache.axiom.om.OMAbstractFactory;

+import org.apache.axiom.om.OMElement;

+import org.apache.axiom.om.OMFactory;

+import org.apache.axiom.om.OMNamespace;

+import org.apache.axiom.om.impl.builder.StAXOMBuilder;

+import org.apache.tuscany.sca.common.xml.stax.StAXHelper;

+import org.apache.tuscany.sca.core.ExtensionPointRegistry;

+import org.apache.tuscany.sca.interfacedef.util.FaultException;

+

+public class AXIOMXMLHelper implements XMLHelper<OMElement> {

+

+    private OMFactory factory;

+    private StAXHelper staxhelper;

+

+    public AXIOMXMLHelper(ExtensionPointRegistry epr) {

+        this.staxhelper = StAXHelper.getInstance(epr);

+        this.factory = OMAbstractFactory.getOMFactory();

+    }

+

+    @Override

+    public OMElement load(String xml) throws IOException {

+        StAXOMBuilder builder;

+        try {

+            builder = new StAXOMBuilder(staxhelper.createXMLStreamReader(xml));

+        } catch (XMLStreamException e) {

+            throw new IOException(e);

+        }

+        return builder.getDocumentElement();

+    }

+

+    @Override

+    public String saveAsString(OMElement t) {

+        // TODO: The JMS compliance tests require the XML prefix but AXIOM doesn't include that

+        return "<?xml version=\"1.0\" encoding=\"UTF-8\"?>" + t.toString();

+    }

+

+    @Override

+    public String getOperationName(OMElement t) {

+        return t.getLocalName();

+    }

+

+    @Override

+    public Object wrap(OMElement template, OMElement os) {

+        OMElement newWrapper = template.cloneOMElement();

+        if (os != null) {

+            os.declareDefaultNamespace(newWrapper.getNamespace().getNamespaceURI());

+            newWrapper.addChild(os);

+        }

+        return newWrapper;

+    }

+

+    @Override

+    public OMElement createWrapper(QName qname) {

+        // The OMElement2JAXB transformer wants the opName to be capitalized

+        String opName = Character.toUpperCase(qname.getLocalPart().charAt(0)) + qname.getLocalPart().substring(1);

+        OMElement om = factory.createOMElement(qname);

+        OMNamespace defaultNS = om.declareDefaultNamespace(qname.getNamespaceURI());

+        return factory.createOMElement(opName, defaultNS);

+    }

+

+    @Override

+    public String getDataBindingName() {

+        return OMElement.class.getName();

+    }

+

+    @Override

+    public OMElement getFirstChild(OMElement o) {

+        return o.getFirstElement();

+    }

+

+    @Override

+    public void setFaultName(FaultException e, Object o) {

+        OMElement om = (OMElement)o;

+        e.setFaultName(new QName(om.getNamespace().getNamespaceURI(), om.getLocalName()));

+    }

+}