1 files changed, 65 insertions, 0 deletions
diff --git a/sandbox/ant/tuscany-container-rhino/src/main/java/org/apache/tuscany/container/rhino/e4x/E4XInterceptor.java b/sandbox/ant/tuscany-container-rhino/src/main/java/org/apache/tuscany/container/rhino/e4x/E4XInterceptor.java
new file mode 100644
index 0000000000..1031a2577c
--- /dev/null
+++ b/sandbox/ant/tuscany-container-rhino/src/main/java/org/apache/tuscany/container/rhino/e4x/E4XInterceptor.java
@@ -0,0 +1,65 @@
+package org.apache.tuscany.container.rhino.e4x;
+
+import java.io.ByteArrayInputStream;
+
+import javax.xml.namespace.QName;
+
+import org.apache.tuscany.core.message.Message;
+import org.apache.tuscany.core.wire.Interceptor;
+import org.apache.tuscany.core.wire.InvocationRuntimeException;
+import org.apache.tuscany.databinding.sdo.SDOXMLHelper;
+import org.apache.xmlbeans.XmlObject;
+
+import commonj.sdo.helper.TypeHelper;
+
+public class E4XInterceptor implements Interceptor {
+
+    private Interceptor next;
+
+    private QName elementQN;
+
+    private TypeHelper typeHelper;
+
+    private ClassLoader classLoader;
+
+    E4XInterceptor(QName elementQN, TypeHelper typeHelper, ClassLoader classLoader) {
+        this.elementQN = elementQN;
+        this.typeHelper = typeHelper;
+        this.classLoader = classLoader;
+    }
+
+    public Message invoke(Message message) {
+        toXmlObject(message);
+        Message responseMessage = next.invoke(message);
+        fromXmlObject(responseMessage);
+        return responseMessage;
+    }
+
+    protected void toXmlObject(Message message) {
+        Object[] body = (Object[]) message.getBody();
+        byte[] xmlBytes = SDOXMLHelper.toXMLBytes(classLoader, typeHelper, body, elementQN, true);
+        try {
+            message.setBody(new Object[] { XmlObject.Factory.parse(new ByteArrayInputStream(xmlBytes)) });
+        } catch (Exception e) {
+            throw new InvocationRuntimeException(e);
+        }
+    }
+
+    protected void fromXmlObject(Message message) {
+        Object body = message.getBody();
+        if (body instanceof XmlObject) {
+            byte[] xmlBytes = ((XmlObject) body).toString().getBytes();
+            Object[] os = SDOXMLHelper.toObjects(classLoader, typeHelper, xmlBytes, true);
+            if (os == null || os.length < 1) {
+                message.setBody(os);
+            } else {
+                message.setBody(os[0]);
+            }
+        }
+    }
+
+    public void setNext(Interceptor next) {
+        this.next = next;
+    }
+
+}