You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by ka...@apache.org on 2009/04/03 20:34:28 UTC

svn commit: r761755 - /ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MexDaoUtil.java

Author: karthick
Date: Fri Apr  3 18:34:28 2009
New Revision: 761755

URL: http://svn.apache.org/viewvc?rev=761755&view=rev
Log:
ODE-561 This new class got left out of the previous checkin.

Added:
    ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MexDaoUtil.java

Added: ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MexDaoUtil.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MexDaoUtil.java?rev=761755&view=auto
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MexDaoUtil.java (added)
+++ ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/MexDaoUtil.java Fri Apr  3 18:34:28 2009
@@ -0,0 +1,43 @@
+package org.apache.ode.bpel.engine;
+
+import javax.xml.namespace.QName;
+
+import org.apache.ode.bpel.dao.MessageDAO;
+import org.apache.ode.bpel.dao.MessageExchangeDAO;
+import org.apache.ode.bpel.iapi.Message;
+import org.apache.ode.bpel.iapi.MessageExchange;
+import org.apache.ode.bpel.iapi.MessageExchange.FailureType;
+import org.apache.ode.bpel.iapi.MessageExchange.Status;
+import org.w3c.dom.Element;
+
+/**
+ * Some handy utilities methods for dealing with MEX impls.
+ *  
+ */
+class MexDaoUtil {
+
+    static void setFailed(MessageExchangeImpl mex, FailureType ftype, String explanation) {
+        mex.setStatus(Status.FAILURE);
+        mex.setFaultExplanation(explanation);
+        mex.setFailure(ftype, explanation, null);
+    }
+
+    static void setFaulted(MessageExchangeImpl mex, QName faultType, Element faultmsg) {
+        mex.setStatus(Status.FAULT);
+        Message flt = mex.createMessage(faultType);
+        flt.setMessage(faultmsg);
+        mex.setFault(faultType, flt);
+    }
+
+    static void setResponse(MessageExchangeImpl mex, QName responseType, Element response) {
+        mex.setStatus(Status.RESPONSE);
+        mex.setFault(null, null);
+        Message resp = mex.createMessage(responseType);
+        resp.setMessage(response);
+        mex.setResponse(resp);
+    }
+
+	public static void setFailure(PartnerRoleMessageExchangeImpl mex, FailureType type, String description, Element details) {
+        mex.replyWithFailure(type, description, details);
+	}
+}