You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by se...@apache.org on 2009/11/06 22:41:06 UTC
svn commit: r833565 -
/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/test/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImplTest.java
Author: seanahn
Date: Fri Nov 6 21:41:05 2009
New Revision: 833565
URL: http://svn.apache.org/viewvc?rev=833565&view=rev
Log:
Rolled back changes from ode-689, r830795
Modified:
ode/branches/APACHE_ODE_1.X/bpel-runtime/src/test/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImplTest.java
Modified: ode/branches/APACHE_ODE_1.X/bpel-runtime/src/test/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImplTest.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/test/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImplTest.java?rev=833565&r1=833564&r2=833565&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-runtime/src/test/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImplTest.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-runtime/src/test/java/org/apache/ode/bpel/engine/MyRoleMessageExchangeImplTest.java Fri Nov 6 21:41:05 2009
@@ -6,7 +6,6 @@
import java.util.concurrent.TimeoutException;
import javax.transaction.TransactionManager;
-import javax.xml.namespace.QName;
import org.apache.geronimo.transaction.manager.GeronimoTransactionManager;
import org.apache.ode.bpel.dao.MessageExchangeDAO;
@@ -24,17 +23,7 @@
TransactionManager _txm;
public void testResponseReceived() throws Exception {
- mexDao.expects(atLeastOnce()).method("getDirection").will(returnValue(MessageExchangeDAO.DIR_PARTNER_INVOKES_MYROLE));
- mexDao.expects(atLeastOnce()).method("getMessageExchangeId").will(returnValue("163"));
- mexDao.expects(atLeastOnce()).method("getCorrelationId").will(returnValue("corrId"));
- mexDao.expects(atLeastOnce()).method("getCorrelationStatus").will(returnValue("MATCHED"));
- mexDao.expects(atLeastOnce()).method("getPattern").will(returnValue("PATTERN"));
- mexDao.expects(atLeastOnce()).method("getCallee").will(returnValue(new QName("CALLEE")));
- mexDao.expects(atLeastOnce()).method("getStatus").will(returnValue("10"));
- mexDao.expects(atLeastOnce()).method("getOperation").will(returnValue("10"));
- mexDao.expects(atLeastOnce()).method("getPipedMessageExchangeId").will(returnValue("163"));
- mexDao.expects(atLeastOnce()).method("getFault").will(returnValue(null));
- mexDao.expects(atLeastOnce()).method("getResponse").will(returnValue(null));
+ mexDao.expects(exactly(3)).method("getCorrelationId").will(returnValue("corrId"));
final boolean[] responded = new boolean[1];
myRoleMexImpl.callbacks().put("corrId", new ResponseCallback() {
@@ -63,18 +52,7 @@
}
public void testResponseTimeout() throws Exception {
- mexDao.expects(atLeastOnce()).method("getDirection").will(returnValue(MessageExchangeDAO.DIR_PARTNER_INVOKES_MYROLE));
- mexDao.expects(atLeastOnce()).method("getMessageExchangeId").will(returnValue("163"));
mexDao.expects(atLeastOnce()).method("getCorrelationId").will(returnValue("corrId"));
- mexDao.expects(atLeastOnce()).method("getCorrelationStatus").will(returnValue("MATCHED"));
- mexDao.expects(atLeastOnce()).method("getPattern").will(returnValue("PATTERN"));
- mexDao.expects(atLeastOnce()).method("getCallee").will(returnValue(new QName("CALLEE")));
- mexDao.expects(atLeastOnce()).method("getStatus").will(returnValue("10"));
- mexDao.expects(atLeastOnce()).method("getOperation").will(returnValue("10"));
- mexDao.expects(atLeastOnce()).method("getPipedMessageExchangeId").will(returnValue("163"));
- mexDao.expects(atLeastOnce()).method("getFault").will(returnValue(null));
- mexDao.expects(atLeastOnce()).method("getResponse").will(returnValue(null));
-
myRoleMexImpl.callbacks().put("corrId", new MyRoleMessageExchangeImpl.ResponseCallback());
_txm.begin();