You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2006/12/10 13:46:54 UTC
svn commit: r485167 [2/2] - in /webservices/sandesha/trunk/java: ./ config/
src/org/apache/sandesha2/ src/org/apache/sandesha2/client/
src/org/apache/sandesha2/i18n/ src/org/apache/sandesha2/msgprocessors/
src/org/apache/sandesha2/polling/ src/org/apac...
Copied: webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/RMSBeanMgrTest.java (from r485157, webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java)
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/RMSBeanMgrTest.java?view=diff&rev=485167&p1=webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java&r1=485157&p2=webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/RMSBeanMgrTest.java&r2=485167
==============================================================================
--- webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java (original)
+++ webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/RMSBeanMgrTest.java Sun Dec 10 04:46:51 2006
@@ -17,8 +17,8 @@
package org.apache.sandesha2.storage;
import org.apache.sandesha2.policy.SandeshaPolicyBean;
-import org.apache.sandesha2.storage.beanmanagers.CreateSeqBeanMgr;
-import org.apache.sandesha2.storage.beans.CreateSeqBean;
+import org.apache.sandesha2.storage.beanmanagers.RMSBeanMgr;
+import org.apache.sandesha2.storage.beans.RMSBean;
import org.apache.sandesha2.util.PropertyManager;
import org.apache.sandesha2.util.SandeshaUtil;
import org.apache.sandesha2.Sandesha2Constants;
@@ -30,12 +30,12 @@
import java.util.Iterator;
-public class CreateSeqBeanMgrTest extends SandeshaTestCase {
- private CreateSeqBeanMgr mgr;
+public class RMSBeanMgrTest extends SandeshaTestCase {
+ private RMSBeanMgr mgr;
Transaction transaction;
- public CreateSeqBeanMgrTest() {
- super("CreateSeqBeanMgrTest");
+ public RMSBeanMgrTest() {
+ super("RMSBeanMgrTest");
}
public void setUp() throws Exception {
@@ -62,22 +62,22 @@
}
public void testDelete() throws SandeshaStorageException {
- CreateSeqBean createSeqBean = new CreateSeqBean ();
- createSeqBean.setInternalSequenceID("TmpSeqId1");
- createSeqBean.setCreateSeqMsgID("CreateSeqMsgId1");
- createSeqBean.setSequenceID("SeqId1");
- mgr.insert(createSeqBean);
+ RMSBean rMSBean = new RMSBean ();
+ rMSBean.setInternalSequenceID("TmpSeqId1");
+ rMSBean.setCreateSeqMsgID("CreateSeqMsgId1");
+ rMSBean.setSequenceID("SeqId1");
+ mgr.insert(rMSBean);
mgr.delete("CreateSeqMsgId1");
assertNull(mgr.retrieve("CreateSeqMsgId1"));
}
public void testFind() throws SandeshaStorageException {
- CreateSeqBean createSeqBean1 = new CreateSeqBean ();
+ RMSBean createSeqBean1 = new RMSBean ();
createSeqBean1.setInternalSequenceID("TmpSeqId1");
createSeqBean1.setCreateSeqMsgID("CreateSeqMsgId1");
createSeqBean1.setSequenceID("SeqId1");
- CreateSeqBean createSeqBean2 = new CreateSeqBean ();
+ RMSBean createSeqBean2 = new RMSBean ();
createSeqBean2.setInternalSequenceID("TmpSeqId1");
createSeqBean2.setCreateSeqMsgID("CreateSeqMsgId2");
createSeqBean2.setSequenceID("SeqId2");
@@ -85,28 +85,28 @@
mgr.insert(createSeqBean1);
mgr.insert(createSeqBean2);
- CreateSeqBean target = new CreateSeqBean();
+ RMSBean target = new RMSBean();
target.setInternalSequenceID("TmpSeqId1");
Iterator iter = mgr.find(target).iterator();
- CreateSeqBean tmp = (CreateSeqBean) iter.next();
+ RMSBean tmp = (RMSBean) iter.next();
if (tmp.getCreateSeqMsgID().equals("CreateSeqMsgId1")) {
- tmp = (CreateSeqBean) iter.next();
+ tmp = (RMSBean) iter.next();
assertTrue(tmp.getCreateSeqMsgID().equals("CreateSeqMsgId2"));
} else {
- tmp = (CreateSeqBean) iter.next();
+ tmp = (RMSBean) iter.next();
assertTrue(tmp.getCreateSeqMsgID().equals("CreateSeqMsgId1"));
}
}
public void testInsert() throws SandeshaStorageException{
- CreateSeqBean createSeqBean = new CreateSeqBean ();
- createSeqBean.setInternalSequenceID("TmpSeqId4");
- createSeqBean.setCreateSeqMsgID("CreateSeqMsgId4");
- createSeqBean.setSequenceID("SeqId4");
- mgr.insert(createSeqBean);
- CreateSeqBean tmpbean = mgr.retrieve("CreateSeqMsgId4");
+ RMSBean rMSBean = new RMSBean ();
+ rMSBean.setInternalSequenceID("TmpSeqId4");
+ rMSBean.setCreateSeqMsgID("CreateSeqMsgId4");
+ rMSBean.setSequenceID("SeqId4");
+ mgr.insert(rMSBean);
+ RMSBean tmpbean = mgr.retrieve("CreateSeqMsgId4");
assertTrue(tmpbean.getCreateSeqMsgID().equals("CreateSeqMsgId4"));
assertTrue(tmpbean.getSequenceID().equals("SeqId4"));
assertTrue(tmpbean.getInternalSequenceID().equals("TmpSeqId4"));
@@ -116,25 +116,25 @@
public void testRetrieve() throws SandeshaStorageException{
assertNull(mgr.retrieve("CreateSeqMsgId5"));
- CreateSeqBean createSeqBean = new CreateSeqBean ();
- createSeqBean.setInternalSequenceID("TmpSeqId5");
- createSeqBean.setCreateSeqMsgID("CreateSeqMsgId5");
- createSeqBean.setSequenceID("SeqId5");
- mgr.insert(createSeqBean);
- CreateSeqBean tmp = mgr.retrieve("CreateSeqMsgId5");
+ RMSBean rMSBean = new RMSBean ();
+ rMSBean.setInternalSequenceID("TmpSeqId5");
+ rMSBean.setCreateSeqMsgID("CreateSeqMsgId5");
+ rMSBean.setSequenceID("SeqId5");
+ mgr.insert(rMSBean);
+ RMSBean tmp = mgr.retrieve("CreateSeqMsgId5");
assertTrue(tmp.getCreateSeqMsgID().equals("CreateSeqMsgId5"));
}
public void testUpdate() throws SandeshaStorageException {
- CreateSeqBean createSeqBean = new CreateSeqBean ();
- createSeqBean.setInternalSequenceID("TmpSeqId6");
- createSeqBean.setCreateSeqMsgID("CreateSeqMsgId6");
- createSeqBean.setSequenceID("SeqId6");
+ RMSBean rMSBean = new RMSBean ();
+ rMSBean.setInternalSequenceID("TmpSeqId6");
+ rMSBean.setCreateSeqMsgID("CreateSeqMsgId6");
+ rMSBean.setSequenceID("SeqId6");
- mgr.insert(createSeqBean);
- createSeqBean.setInternalSequenceID("TmpSeqId7");
- mgr.update(createSeqBean);
- CreateSeqBean tmp = mgr.retrieve("CreateSeqMsgId6");
+ mgr.insert(rMSBean);
+ rMSBean.setInternalSequenceID("TmpSeqId7");
+ mgr.update(rMSBean);
+ RMSBean tmp = mgr.retrieve("CreateSeqMsgId6");
assertTrue(tmp.getInternalSequenceID().equals("TmpSeqId7"));
}
}
Copied: webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/SenderBeanMgrTest.java (from r485157, webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java)
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/SenderBeanMgrTest.java?view=diff&rev=485167&p1=webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java&r1=485157&p2=webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/SenderBeanMgrTest.java&r2=485167
==============================================================================
--- webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java (original)
+++ webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/storage/SenderBeanMgrTest.java Sun Dec 10 04:46:51 2006
@@ -31,13 +31,13 @@
import java.util.Iterator;
-public class RetransmitterBeanMgrTest extends SandeshaTestCase {
+public class SenderBeanMgrTest extends SandeshaTestCase {
private SenderBeanMgr mgr;
Transaction transaction;
- public RetransmitterBeanMgrTest() {
- super("RetransmitterBeanMgrTest");
+ public SenderBeanMgrTest() {
+ super("SenderBeanMgrTest");
}
public void setUp() throws Exception {
Modified: webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/workers/ForceInboundDispatchTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/workers/ForceInboundDispatchTest.java?view=diff&rev=485167&r1=485166&r2=485167
==============================================================================
--- webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/workers/ForceInboundDispatchTest.java (original)
+++ webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/workers/ForceInboundDispatchTest.java Sun Dec 10 04:46:51 2006
@@ -15,7 +15,7 @@
import org.apache.sandesha2.client.SandeshaClientConstants;
import org.apache.sandesha2.storage.StorageManager;
import org.apache.sandesha2.storage.Transaction;
-import org.apache.sandesha2.storage.beans.NextMsgBean;
+import org.apache.sandesha2.storage.beans.RMDBean;
import org.apache.sandesha2.storage.beans.SequencePropertyBean;
import org.apache.sandesha2.util.RangeString;
import org.apache.sandesha2.util.SandeshaUtil;
@@ -76,10 +76,10 @@
//check that the server is now expecting msg 4
StorageManager serverStore = SandeshaUtil.getInMemoryStorageManager(serverConfigCtx);
t = serverStore.getTransaction();
- NextMsgBean nextMsgBean =
+ RMDBean rMDBean =
serverStore.getNextMsgBeanMgr().retrieve(inboundSequenceID);
- assertNotNull(nextMsgBean);
- assertEquals(nextMsgBean.getNextMsgNoToProcess(), 4);
+ assertNotNull(rMDBean);
+ assertEquals(rMDBean.getNextMsgNoToProcess(), 4);
//also check that the sequence has an out of order gap that contains msg 2
SequencePropertyBean outOfOrderRanges =
@@ -152,9 +152,9 @@
//check that the server is now expecting msg 4
StorageManager serverMgr = SandeshaUtil.getInMemoryStorageManager(serverConfigCtx);
t = serverMgr.getTransaction();
- NextMsgBean nextMsgBean = serverMgr.getNextMsgBeanMgr().retrieve(inboundSequenceID);
- assertNotNull(nextMsgBean);
- assertEquals(nextMsgBean.getNextMsgNoToProcess(), 4);
+ RMDBean rMDBean = serverMgr.getNextMsgBeanMgr().retrieve(inboundSequenceID);
+ assertNotNull(rMDBean);
+ assertEquals(rMDBean.getNextMsgNoToProcess(), 4);
t.commit();
}
finally{
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org