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);
+ }
+}