You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ga...@apache.org on 2009/02/13 14:21:18 UTC
svn commit: r744107 -
/webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/faulttests/SequenceTerminatedFaultTest.java
Author: gatfora
Date: Fri Feb 13 13:21:18 2009
New Revision: 744107
URL: http://svn.apache.org/viewvc?rev=744107&view=rev
Log:
Modifying SequenceTerminatedFault test to remove ordering problem when finding RMDBeans
Modified:
webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/faulttests/SequenceTerminatedFaultTest.java
Modified: webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/faulttests/SequenceTerminatedFaultTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/faulttests/SequenceTerminatedFaultTest.java?rev=744107&r1=744106&r2=744107&view=diff
==============================================================================
--- webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/faulttests/SequenceTerminatedFaultTest.java (original)
+++ webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/faulttests/SequenceTerminatedFaultTest.java Fri Feb 13 13:21:18 2009
@@ -20,6 +20,7 @@
import java.io.File;
import java.io.OutputStream;
import java.net.HttpURLConnection;
+import java.util.Iterator;
import java.util.List;
import org.apache.axiom.soap.SOAP12Constants;
@@ -307,6 +308,26 @@
}
private void runSequenceTerminated(boolean deleteRMSBean, boolean soap12) throws Exception {
+
+ // Check that the sequence has been deleted.
+ StorageManager storageManager =
+ SandeshaUtil.getSandeshaStorageManager(serverConfigContext, serverConfigContext.getAxisConfiguration());
+
+ Transaction tran = storageManager.getTransaction();
+
+ RMDBean finderBean = new RMDBean();
+ finderBean.setTerminated(false);
+ List<RMDBean> rmdBeans = storageManager.getRMDBeanMgr().find(finderBean);
+
+ Iterator beans = rmdBeans.iterator();
+ while (beans.hasNext())
+ {
+ RMDBean theBean = (RMDBean)beans.next();
+ storageManager.getRMDBeanMgr().delete(theBean.getSequenceID());
+ }
+
+ tran.commit();
+
String to = "http://127.0.0.1:" + serverPort + "/axis2/services/RMSampleService";
String repoPath = "target" + File.separator + "repos" + File.separator + "client";
@@ -337,15 +358,9 @@
while(System.currentTimeMillis() < limit) {
Thread.sleep(tickTime); // Try the assertions each tick interval, until they pass or we time out
- // Check that the sequence has been deleted.
- StorageManager storageManager =
- SandeshaUtil.getSandeshaStorageManager(serverConfigContext, serverConfigContext.getAxisConfiguration());
-
- Transaction tran = storageManager.getTransaction();
+ tran = storageManager.getTransaction();
- RMDBean finderBean = new RMDBean();
- finderBean.setTerminated(false);
- List<RMDBean> rmdBeans = storageManager.getRMDBeanMgr().find(finderBean);
+ rmdBeans = storageManager.getRMDBeanMgr().find(finderBean);
tran.commit();
@@ -354,7 +369,7 @@
if (rmdBeans.isEmpty())
lastError = new Error("rmdBeans empty " + rmdBeans);
else {
- RMDBean bean = (RMDBean)rmdBeans.get(0);
+ RMDBean bean = rmdBeans.get(0);
if (!bean.getServerCompletedMessages().getContainedElementsAsNumbersList().contains(new Integer(1))) {
tran = storageManager.getTransaction();
if (deleteRMSBean) {
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org