Author: chamikara
Date: Sun Oct 30 21:21:13 2005
New Revision: 329750
URL: http://svn.apache.org/viewcvs?rev=329750&view=rev
Log:
moved the test files to the test/src folder and did some corrections.
Added:
webservices/sandesha/trunk/test/src/
webservices/sandesha/trunk/test/src/org/
webservices/sandesha/trunk/test/src/org/apache/
webservices/sandesha/trunk/test/src/org/apache/sandesha2/
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/NextMsgBeanMgrTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/SequencePropertyBeanMgrTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/StorageMapBeanMgrTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceResponseTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceAcknowledgementTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/TerminateSequenceTest.java
Removed:
webservices/sandesha/trunk/test/org/
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaTestCase.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,87 @@
+package org.apache.sandesha2;
+
+import junit.framework.TestCase;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.axis2.engine.AxisConfigurationImpl;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.om.OMAbstractFactory;
+import org.apache.axis2.om.OMXMLParserWrapper;
+import org.apache.axis2.om.impl.llom.factory.OMXMLBuilderFactory;
+
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamException;
+import java.io.*;
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+public class SandeshaTestCase extends TestCase {
+ String resourceDir = "test-resources";
+
+ public SandeshaTestCase(String name) {
+ super(name);
+ File baseDir = new File("");
+ String testRource = baseDir.getAbsolutePath() + File.separator +
"test-resources";
+ resourceDir = new File(testRource).getPath();
+
+ }
+
+ protected InputStreamReader getResource(String relativePath, String
resourceName) {
+ String resourceFile = resourceDir + relativePath + File.separator +
resourceName;
+ String file = new
File("/home/sanka/sandesha2-src/trunk/test-resources/CreateSequence.xml").getPath();
+
+ try {
+ FileReader reader = new FileReader(resourceFile);
+ return reader;
+ } catch (FileNotFoundException e) {
+ throw new RuntimeException("cannot load the test-resource", e);
+ }
+ }
+
+ protected SOAPEnvelope getSOAPEnvelope() {
+ return OMAbstractFactory.getSOAP11Factory().getDefaultEnvelope();
+ }
+
+ protected SOAPEnvelope getSOAPEnvelope(String relativePath, String
resourceName) {
+ try {
+ XMLStreamReader reader =
XMLInputFactory.newInstance().createXMLStreamReader(
+ getResource(relativePath, resourceName));
+ OMXMLParserWrapper wrapper =
OMXMLBuilderFactory.createStAXSOAPModelBuilder(
+ OMAbstractFactory.getSOAP11Factory(), reader);
+ return (SOAPEnvelope) wrapper.getDocumentElement();
+
+ } catch (XMLStreamException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ protected SOAPEnvelope getEmptySOAPEnvelope() {
+ return OMAbstractFactory.getSOAP11Factory().getDefaultEnvelope();
+ }
+
+
+ private MessageContext getMessageContext() throws Exception{
+ AxisConfiguration axisConfig = new AxisConfigurationImpl();
+ ConfigurationContext configCtx = new ConfigurationContext(axisConfig);
+ MessageContext msgCtx = new MessageContext(configCtx);
+ return msgCtx;
+
+ }
+
+
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/CreateSeqBeanMgrTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,94 @@
+package org.apache.sandesha2.storage;
+
+import org.apache.sandesha2.storage.beanmanagers.CreateSeqBeanMgr;
+import org.apache.sandesha2.storage.beans.CreateSeqBean;
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.axis2.engine.AxisConfigurationImpl;
+import org.apache.axis2.context.ConfigurationContext;
+
+import java.util.Iterator;
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+public class CreateSeqBeanMgrTest extends SandeshaTestCase {
+ private CreateSeqBeanMgr mgr;
+
+ public CreateSeqBeanMgrTest() {
+ super("CreateSeqBeanMgrTest");
+ }
+
+ public void setUp() throws Exception {
+ AxisConfiguration axisConfig = new AxisConfigurationImpl();
+ ConfigurationContext configCtx = new ConfigurationContext(axisConfig);
+
+ mgr =
AbstractBeanMgrFactory.getInstance(configCtx).getCreateSeqBeanMgr();
+ }
+
+ public void testDelete() {
+ mgr.insert(new CreateSeqBean("TmpSeqId1", "CreateSeqMsgId1",
"SeqId1"));
+ mgr.delete("CreateSeqMsgId1");
+ assertNull(mgr.retrieve("CreateSeqMsgId1"));
+ }
+
+ public void testFind() {
+ mgr.insert(new CreateSeqBean("TmpSeqId2", "CreateSeqMsgId2",
"SeqId2"));
+ mgr.insert(new CreateSeqBean("TmpSeqId2", "CreateSeqMsgId3",
"SeqId3"));
+
+ CreateSeqBean target = new CreateSeqBean();
+ target.setTempSequenceId("TmpSeqId2");
+
+ Iterator iter = mgr.find(target).iterator();
+ CreateSeqBean tmp = (CreateSeqBean) iter.next();
+ if (tmp.getCreateSeqMsgId().equals("CreateSeqMsgId1")) {
+ tmp = (CreateSeqBean) iter.next();
+ assertTrue(tmp.getCreateSeqMsgId().equals("CreateSeqMsgId2"));
+
+ } else {
+ tmp = (CreateSeqBean) iter.next();
+ assertTrue(tmp.getCreateSeqMsgId().equals("CreateSeqMsgId3"));
+ }
+ }
+
+ public void testInsert() {
+ CreateSeqBean bean = new CreateSeqBean("TmpSeqId4", "CreateSeqMsgId4",
"SeqId4");
+ mgr.insert(bean);
+ CreateSeqBean tmpbean = mgr.retrieve("CreateSeqMsgId4");
+ assertTrue(tmpbean.getCreateSeqMsgId().equals("CreateSeqMsgId4"));
+ assertTrue(tmpbean.getSequenceId().equals("SeqId4"));
+ assertTrue(tmpbean.getTempSequenceId().equals("TmpSeqId4"));
+ }
+
+
+ public void testRetrieve() {
+ assertNull(mgr.retrieve("CreateSeqMsgId5"));
+
+ CreateSeqBean bean = new CreateSeqBean("TmpSeqId5", "CreateSeqMsgId5",
"SeqId5");
+ mgr.insert(bean);
+ CreateSeqBean tmp = mgr.retrieve("CreateSeqMsgId5");
+ assertTrue(tmp.getCreateSeqMsgId().equals("CreateSeqMsgId5"));
+ }
+
+ public void testUpdate() {
+
+ CreateSeqBean bean = new CreateSeqBean("TmpSeqId6", "CreateSeqMsgId6",
"SeqId6");
+ mgr.insert(bean);
+ bean.setTempSequenceId("TmpSeqId7");
+ mgr.update(bean);
+ CreateSeqBean tmp = mgr.retrieve("CreateSeqMsgId6");
+ assertTrue(tmp.getTempSequenceId().equals("TmpSeqId7"));
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/NextMsgBeanMgrTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/NextMsgBeanMgrTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/NextMsgBeanMgrTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/NextMsgBeanMgrTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,91 @@
+package org.apache.sandesha2.storage;
+
+import org.apache.sandesha2.storage.beanmanagers.NextMsgBeanMgr;
+import org.apache.sandesha2.storage.beans.NextMsgBean;
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.axis2.engine.AxisConfigurationImpl;
+import org.apache.axis2.context.ConfigurationContext;
+
+import java.util.Iterator;
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+public class NextMsgBeanMgrTest extends SandeshaTestCase {
+ private NextMsgBeanMgr mgr;
+
+ public NextMsgBeanMgrTest(String name) {
+ super(name);
+ }
+
+ public void setUp() throws Exception {
+ AxisConfiguration axisConfig = new AxisConfigurationImpl();
+ ConfigurationContext configCtx = new ConfigurationContext(axisConfig);
+ mgr =
AbstractBeanMgrFactory.getInstance(configCtx).getNextMsgBeanMgr();
+
+ }
+
+ public void testDelete() {
+ mgr.insert(new NextMsgBean("SeqId1", 1001));
+ mgr.delete("SeqId1");
+ assertNull(mgr.retrieve("SeqId1"));
+ }
+
+ public void testFind() {
+ mgr.insert(new NextMsgBean("SeqId2", 1002));
+ mgr.insert(new NextMsgBean("SeqId3", 1002));
+
+ NextMsgBean target = new NextMsgBean();
+ target.setNextMsgNoToProcess(1002);
+
+ Iterator iterator = mgr.find(target).iterator();
+ NextMsgBean tmp = (NextMsgBean) iterator.next();
+
+ if (tmp.getSequenceId().equals("SeqId2")) {
+ tmp = (NextMsgBean) iterator.next();
+ tmp.getSequenceId().equals("SeqId3");
+ } else {
+ tmp = (NextMsgBean) iterator.next();
+ tmp.getSequenceId().equals("SeqId2");
+ }
+
+ }
+
+ public void testInsert() {
+ NextMsgBean bean = new NextMsgBean("SeqId4", 1004);
+ mgr.insert(bean);
+ NextMsgBean tmp = mgr.retrieve("SeqId4");
+ assertTrue(tmp.getNextMsgNoToProcess() == 1004);
+ }
+
+ public void testRetrieve() {
+ assertNull(mgr.retrieve("SeqId5"));
+ mgr.insert(new NextMsgBean("SeqId5", 1005));
+
+ NextMsgBean tmp = mgr.retrieve("SeqId5");
+ assertTrue(tmp.getNextMsgNoToProcess() == 1005);
+ }
+
+ public void testUpdate() {
+ NextMsgBean bean = new NextMsgBean("SeqId6", 1006);
+ mgr.insert(bean);
+ bean.setNextMsgNoToProcess(1007);
+ mgr.update(bean);
+ NextMsgBean tmp = mgr.retrieve("SeqId6");
+ assertTrue(tmp.getNextMsgNoToProcess() ==1007);
+ }
+
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/RetransmitterBeanMgrTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,121 @@
+package org.apache.sandesha2.storage;
+
+import org.apache.sandesha2.SandeshaException;
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.sandesha2.storage.beanmanagers.RetransmitterBeanMgr;
+import org.apache.sandesha2.storage.beans.RetransmitterBean;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.axis2.engine.AxisConfigurationImpl;
+import org.apache.axis2.context.ConfigurationContext;
+
+import java.util.Iterator;
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+public class RetransmitterBeanMgrTest extends SandeshaTestCase {
+ private RetransmitterBeanMgr mgr;
+
+ public RetransmitterBeanMgrTest() {
+ super("RetransmitterBeanMgrTest");
+ }
+
+ public void setUp() throws Exception {
+ AxisConfiguration axisConfig = new AxisConfigurationImpl();
+ ConfigurationContext configCtx = new ConfigurationContext(axisConfig);
+ mgr =
AbstractBeanMgrFactory.getInstance(configCtx).getRetransmitterBeanMgr();
+ }
+
+ public void testDelete() {
+ assertNull(mgr.retrieve(""));
+ try {
+ mgr.insert(new RetransmitterBean("MsgId1", "Key1", 1001, false,
"TmpSeqId1", 1001));
+ } catch (Exception ex) {
+ fail("should not throw an exception");
+ }
+ assertNotNull(mgr.retrieve("MsgId1"));
+ }
+
+ public void testFind() {
+ try {
+ mgr.insert(new RetransmitterBean("MsgId2", "Key2", 1002, false,
"TmpSeqId2", 1002));
+ mgr.insert(new RetransmitterBean("MsgId3", "Key3", 1003, false,
"TmpSeqId2", 1003));
+
+ RetransmitterBean target = new RetransmitterBean();
+ target.setTempSequenceId("TmpSeqId2");
+
+ Iterator iterator = mgr.find(target).iterator();
+ RetransmitterBean tmp = (RetransmitterBean) iterator.next();
+
+ if (tmp.getMessageId().equals("MsgId2")) {
+ tmp = (RetransmitterBean) iterator.next();
+ assertTrue(tmp.getMessageId().equals("MsgId3"));
+ } else {
+ tmp = (RetransmitterBean) iterator.next();
+ assertTrue(tmp.getMessageId().equals("MsgId2"));
+ }
+
+
+ } catch (SandeshaException e) {
+ fail("should not throw an exception");
+ }
+
+
+ }
+
+ public void testInsert() {
+ try {
+ mgr.insert(new RetransmitterBean());
+ fail("should throw an exception");
+
+ } catch (SandeshaException ex) {
+ }
+
+ try {
+ mgr.insert(new RetransmitterBean("MsgId4","Key4", 1004, false,
"TmpSeqId4", 1004));
+ RetransmitterBean tmp = mgr.retrieve("MsgId4");
+ assertTrue(tmp.getKey().equals("Key4"));
+
+
+ } catch (SandeshaException e) {
+ fail("should not throw an exception");
+ }
+
+ }
+
+ public void testRetrieve() {
+ assertNull(mgr.retrieve("MsgId5"));
+ try {
+ mgr.insert(new RetransmitterBean("MsgId5", "Key5", 1005, false,
"TmpSeqId5", 1005));
+ } catch (SandeshaException e) {
+ fail("this should not throw an exception");
+ }
+ assertNotNull(mgr.retrieve("MsgId5"));
+ }
+
+ public void testUpdate() {
+ RetransmitterBean bean = new RetransmitterBean("MsgId6", "Key6", 1006,
false, "TmpSeqId6", 1006);
+ try {
+ mgr.insert(bean);
+ } catch (SandeshaException e) {
+ fail("should not throw an exception");
+ }
+ bean.setSend(true);
+ mgr.update(bean);
+
+ RetransmitterBean tmp = mgr.retrieve("MsgId6");
+ assertTrue(tmp.isSend());
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/SequencePropertyBeanMgrTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/SequencePropertyBeanMgrTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/SequencePropertyBeanMgrTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/SequencePropertyBeanMgrTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,86 @@
+package org.apache.sandesha2.storage;
+
+import org.apache.sandesha2.storage.beanmanagers.SequencePropertyBeanMgr;
+import org.apache.sandesha2.storage.beans.SequencePropertyBean;
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.axis2.engine.AxisConfigurationImpl;
+import org.apache.axis2.context.ConfigurationContext;
+
+import java.util.Iterator;
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+public class SequencePropertyBeanMgrTest extends SandeshaTestCase {
+ SequencePropertyBeanMgr mgr;
+
+ public SequencePropertyBeanMgrTest() {
+ super("SequencePropertyBeanMgrTest");
+ }
+
+ public void setUp() throws Exception {
+ AxisConfiguration axisConfig = new AxisConfigurationImpl();
+ ConfigurationContext configCtx = new ConfigurationContext(axisConfig);
+ mgr =
AbstractBeanMgrFactory.getInstance(configCtx).getSequencePropretyBeanMgr();
+
+ }
+
+ public void testDelete() {
+ mgr.insert(new SequencePropertyBean("SeqId1", "Name1", "Value1"));
+ mgr.delete("SeqId1", "Name1");
+ assertNull(mgr.retrieve("SeqId1", "Name1"));
+ }
+
+ public void testFind() {
+ mgr.insert(new SequencePropertyBean("SeqId2", "Name2", "Value2"));
+ mgr.insert(new SequencePropertyBean("SeqId3", "Name3", "Value2"));
+
+ SequencePropertyBean bean = new SequencePropertyBean();
+ bean.setValue("Value2");
+ Iterator iter = mgr.find(bean).iterator();
+ SequencePropertyBean tmp = (SequencePropertyBean) iter.next();
+ if (tmp.getSequenceId().equals("SeqId2")) {
+ tmp = (SequencePropertyBean) iter.next();
+ assertTrue(tmp.getSequenceId().equals("SeqId3"));
+ } else {
+ tmp = (SequencePropertyBean) iter.next();
+ assertTrue(tmp.getSequenceId().equals("SeqId2"));
+ }
+ }
+
+ public void testInsert() {
+ mgr.insert(new SequencePropertyBean("SeqId4", "Name4", "Value4"));
+ SequencePropertyBean tmp = mgr.retrieve("SeqId4", "Name4");
+ assertTrue(tmp.getValue().equals("Value4"));
+
+ }
+
+ public void testRetrieve() {
+ assertNull(mgr.retrieve("SeqId5", "Name5"));
+ mgr.insert(new SequencePropertyBean("SeqId5", "Name5", "Value5"));
+ assertNotNull(mgr.retrieve("SeqId5", "Name5"));
+ }
+
+
+ public void testUpdate() {
+ SequencePropertyBean bean = new SequencePropertyBean("SeqId6",
"Name6", "Value6");
+ mgr.insert(bean);
+ bean.setValue("Value7");
+ mgr.update(bean);
+ SequencePropertyBean tmp = mgr.retrieve("SeqId6", "Name6");
+ assertTrue(tmp.getValue().equals("Value7"));
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/StorageMapBeanMgrTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/StorageMapBeanMgrTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/StorageMapBeanMgrTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/storage/StorageMapBeanMgrTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,86 @@
+package org.apache.sandesha2.storage;
+
+import org.apache.sandesha2.storage.beanmanagers.StorageMapBeanMgr;
+import org.apache.sandesha2.storage.beans.StorageMapBean;
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.axis2.engine.AxisConfiguration;
+import org.apache.axis2.engine.AxisConfigurationImpl;
+import org.apache.axis2.context.ConfigurationContext;
+
+import java.util.Iterator;
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+public class StorageMapBeanMgrTest extends SandeshaTestCase {
+
+ StorageMapBeanMgr mgr;
+
+ public StorageMapBeanMgrTest() {
+ super ("StorageMapBeanMgrTest");
+ }
+
+ public void setUp() throws Exception {
+ AxisConfiguration axisConfig = new AxisConfigurationImpl();
+ ConfigurationContext configCtx = new ConfigurationContext(axisConfig);
+ mgr =
AbstractBeanMgrFactory.getInstance(configCtx).getStorageMapBeanMgr();
+ }
+
+ public void testDelete() {
+ mgr.insert(new StorageMapBean("Key1", 1001, "SeqId1"));
+ mgr.delete("Key1");
+ assertNull(mgr.retrieve("Key1"));
+ }
+
+ public void testFind() {
+ mgr.insert(new StorageMapBean("Key2", 1002, "SeqId2"));
+ mgr.insert(new StorageMapBean("Key3", 1003, "SeqId2"));
+
+ StorageMapBean bean = new StorageMapBean();
+ bean.setSequenceId("SeqId2");
+
+ Iterator iter = mgr.find(bean).iterator();
+ StorageMapBean tmp = (StorageMapBean) iter.next();
+
+ if (tmp.getKey().equals("Key2")) {
+ tmp = (StorageMapBean) iter.next();
+ assertTrue(tmp.getKey().equals("Key3"));
+ } else {
+ tmp = (StorageMapBean) iter.next();
+ assertTrue(tmp.getKey().equals("Key2"));
+
+ }
+ }
+
+ public void testInsert() {
+ mgr.insert(new StorageMapBean("Key4", 1004, "SeqId4"));
+ StorageMapBean tmp = mgr.retrieve("Key4");
+ assertTrue(tmp.getKey().equals("Key4"));
+ }
+
+ public void testRetrieve() {
+ assertNull(mgr.retrieve("Key5"));
+ mgr.insert(new StorageMapBean("Key5", 1004, "SeqId5"));
+ assertNotNull(mgr.retrieve("Key5"));
+ }
+
+ public void testUpdate() {
+ StorageMapBean bean = new StorageMapBean("Key6", 1006, "SeqId6");
+ mgr.insert(bean);
+ bean.setMsgNo(1007);
+ StorageMapBean tmp = mgr.retrieve("Key6");
+ assertTrue(tmp.getMsgNo() == 1007);
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceResponseTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceResponseTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceResponseTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceResponseTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,72 @@
+package org.apache.sandesha2.wsrm;
+
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.sandesha2.Constants;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.om.OMElement;
+
+import javax.xml.namespace.QName;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: sanka
+ * Date: Oct 7, 2005
+ * Time: 2:43:50 AM
+ * To change this template use File | Settings | File Templates.
+ */
+public class CreateSequenceResponseTest extends SandeshaTestCase {
+
+ public CreateSequenceResponseTest() {
+ super("CreateSequenceResponseTest");
+
+ }
+
+ public void testFromOMElement() {
+ CreateSequenceResponse res = new CreateSequenceResponse();
+ SOAPEnvelope env = getSOAPEnvelope("", "CreateSequenceResponse.xml");
+ res.fromOMElement(env.getBody());
+
+ Identifier identifier = res.getIdentifier();
+ assertEquals("uuid:88754b00-161a-11da-b6d6-8198de3c47c5",
identifier.getIdentifier());
+
+ Accept accept = res.getAccept();
+ AcksTo acksTo = accept.getAcksTo();
+ Address address = acksTo.getAddress();
+ assertEquals("http://localhost:8070/axis/services/TestService";,
address.getEpr().getAddress());
+
+ }
+
+ public void testToSOAPEnvelope() {
+ CreateSequenceResponse res = new CreateSequenceResponse();
+
+ Identifier identifier = new Identifier();
+ identifier.setIndentifer("uuid:88754b00-161a-11da-b6d6-8198de3c47c5");
+ res.setIdentifier(identifier);
+
+ Accept accept = new Accept();
+ AcksTo acksTo = new AcksTo();
+ Address address = new Address();
+ address.setEpr(new
EndpointReference("http://localhost:8070/axis/services/TestService";));
+ acksTo.setAddress(address);
+ accept.setAcksTo(acksTo);
+ res.setAccept(accept);
+
+ SOAPEnvelope env = getEmptySOAPEnvelope();
+ res.toSOAPEnvelope(env);
+
+ OMElement createSeqResponsePart = env.getBody().getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.CREATE_SEQUENCE_RESPONSE));
+ OMElement identifierPart = createSeqResponsePart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.IDENTIFIER));
+ assertEquals("uuid:88754b00-161a-11da-b6d6-8198de3c47c5",
identifierPart.getText());
+
+ OMElement acceptPart = createSeqResponsePart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM, Constants.WSRM.ACCEPT));
+ OMElement acksToPart = acceptPart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM, Constants.WSRM.ACKS_TO));
+ OMElement addressPart = acksToPart.getFirstChildWithName(new QName(
+ Constants.WSA.NS_URI_ADDRESSING,
Constants.WSA.ADDRESS));
+ assertEquals("http://localhost:8070/axis/services/TestService";,
addressPart.getText());
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/CreateSequenceTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,71 @@
+package org.apache.sandesha2.wsrm;
+
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.sandesha2.Constants;
+import org.apache.sandesha2.wsrm.*;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.om.OMElement;
+
+import javax.xml.namespace.QName;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: sanka
+ * Date: Oct 6, 2005
+ * Time: 10:39:03 PM
+ * To change this template use File | Settings | File Templates.
+ */
+public class CreateSequenceTest extends SandeshaTestCase {
+
+ public CreateSequenceTest() {
+ super("CreateSequenceTest");
+ }
+
+ public void testfromOMElement() {
+ CreateSequence createSequence = new CreateSequence();
+ createSequence.fromOMElement(getSOAPEnvelope("",
"CreateSequence.xml").getBody());
+
+ AcksTo acksTo = createSequence.getAcksTo();
+ Address address = acksTo.getAddress();
+ assertEquals("http://127.0.0.1:9090/axis/services/RMService";,
address.getEpr().getAddress());
+
+ SequenceOffer offer = createSequence.getSequenceOffer();
+ Identifier identifier = offer.getIdentifer();
+ assertEquals("uuid:c3671020-15e0-11da-9b3b-f0439d4867bd",
identifier.getIdentifier());
+
+ }
+
+ public void testToSOAPEnvelope() {
+ CreateSequence createSequence = new CreateSequence();
+
+ AcksTo acksTo = new AcksTo();
+ Address address = new Address();
+ address.setEpr(new
EndpointReference("http://127.0.0.1:9090/axis/services/RMService";));
+ acksTo.setAddress(address);
+ createSequence.setAcksTo(acksTo);
+
+ SequenceOffer sequenceOffer = new SequenceOffer();
+ Identifier identifier = new Identifier();
+ identifier.setIndentifer("uuid:c3671020-15e0-11da-9b3b-f0439d4867bd");
+ sequenceOffer.setIdentifier(identifier);
+ createSequence.setSequenceOffer(sequenceOffer);
+
+ SOAPEnvelope envelope = getEmptySOAPEnvelope();
+ createSequence.toSOAPEnvelope(envelope);
+
+ OMElement createSequencePart =
envelope.getBody().getFirstChildWithName(new QName(Constants.WSRM.NS_URI_RM,
+ Constants.WSRM.CREATE_SEQUENCE));
+ OMElement acksToPart = createSequencePart.getFirstChildWithName(new
QName(
+ Constants.WSRM.NS_URI_RM,
Constants.WSRM.ACKS_TO));
+ OMElement addressPart = acksToPart.getFirstChildWithName(new
QName(
+ Constants.WSA.NS_URI_ADDRESSING, Constants.WSA.ADDRESS));
+ assertEquals("http://127.0.0.1:9090/axis/services/RMService";,
addressPart.getText());
+
+ OMElement offerPart = createSequencePart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.SEQUENCE_OFFER));
+ OMElement identifierPart = offerPart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.IDENTIFIER));
+ assertEquals("uuid:c3671020-15e0-11da-9b3b-f0439d4867bd",
identifierPart.getText());
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceAcknowledgementTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceAcknowledgementTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceAcknowledgementTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceAcknowledgementTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,80 @@
+package org.apache.sandesha2.wsrm;
+
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.sandesha2.Constants;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.om.OMElement;
+
+import javax.xml.namespace.QName;
+import java.util.Iterator;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: sanka
+ * Date: Oct 7, 2005
+ * Time: 3:52:12 AM
+ * To change this template use File | Settings | File Templates.
+ */
+public class SequenceAcknowledgementTest extends SandeshaTestCase {
+
+ public SequenceAcknowledgementTest() {
+ super("SequenceAcknowledgementTest");
+ }
+
+ public void testFromOMElement() {
+ SequenceAcknowledgement sequenceAck = new SequenceAcknowledgement();
+ SOAPEnvelope env = getSOAPEnvelope("", "SequenceAcknowledgement.xml");
+ sequenceAck.fromOMElement(env.getHeader());
+
+ Identifier identifier = sequenceAck.getIdentifier();
+ assertEquals("uuid:897ee740-1624-11da-a28e-b3b9c4e71445",
identifier.getIdentifier());
+
+ Iterator iterator = sequenceAck.getAcknowledgementRanges().iterator();
+ while (iterator.hasNext()) {
+ AcknowledgementRange ackRange = (AcknowledgementRange)
iterator.next();
+ if (ackRange.getLowerValue() == 1){
+ assertEquals(2, ackRange.getUpperValue());
+
+ } else if (ackRange.getLowerValue() == 4) {
+ assertEquals(6, ackRange.getUpperValue());
+
+ } else if (ackRange.getLowerValue() == 8) {
+ assertEquals(10, ackRange.getUpperValue());
+ }
+ }
+
+ iterator = sequenceAck.getNackList().iterator();
+ while (iterator.hasNext()) {
+ Nack nack = (Nack) iterator.next();
+ if (nack.getNackNumber() == 3) {
+
+ } else if (nack.getNackNumber() == 7) {
+
+ } else {
+ fail("invalid nack : " + nack.getNackNumber());
+ }
+ }
+
+
+ }
+
+ public void testToOMElement() {
+ SequenceAcknowledgement seqAck = new SequenceAcknowledgement();
+ Identifier identifier = new Identifier();
+ identifier.setIndentifer("uuid:897ee740-1624-11da-a28e-b3b9c4e71445");
+ seqAck.setIdentifier(identifier);
+
+ SOAPEnvelope env = getEmptySOAPEnvelope();
+ seqAck.toSOAPEnvelope(env);
+
+ OMElement sequenceAckPart = env.getHeader().getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.SEQUENCE_ACK));
+ OMElement identifierPart = sequenceAckPart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.IDENTIFIER));
+ assertEquals("uuid:897ee740-1624-11da-a28e-b3b9c4e71445",
identifierPart.getText());
+
+
+
+
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/SequenceTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,60 @@
+package org.apache.sandesha2.wsrm;
+
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.sandesha2.Constants;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.om.OMElement;
+
+import javax.xml.namespace.QName;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: sanka
+ * Date: Oct 7, 2005
+ * Time: 4:31:54 AM
+ * To change this template use File | Settings | File Templates.
+ */
+public class SequenceTest extends SandeshaTestCase {
+
+ public SequenceTest() {
+ super("SequenceTest");
+
+ }
+
+ public void testFromOMElement() {
+ SOAPEnvelope env = getSOAPEnvelope("", "Sequence.xml");
+ Sequence sequence = new Sequence();
+ sequence.fromOMElement(env.getHeader());
+
+ Identifier identifier = sequence.getIdentifier();
+ assertEquals("uuid:879da420-1624-11da-bed9-84d13db13902",
identifier.getIdentifier());
+
+ MessageNumber msgNo = sequence.getMessageNumber();
+ assertEquals(1, msgNo.getMessageNumber());
+ }
+
+ public void testToSOAPEnvelope() {
+ Sequence sequence = new Sequence();
+
+ Identifier identifier = new Identifier();
+ identifier.setIndentifer("uuid:879da420-1624-11da-bed9-84d13db13902");
+ sequence.setIdentifier(identifier);
+
+ MessageNumber msgNo = new MessageNumber();
+ msgNo.setMessageNumber(1);
+ sequence.setMessageNumber(msgNo);
+
+ SOAPEnvelope envelope = getEmptySOAPEnvelope();
+ sequence.toSOAPEnvelope(envelope);
+
+ OMElement sequencePart = envelope.getHeader().getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM, Constants.WSRM.SEQUENCE));
+ OMElement identifierPart = sequencePart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.IDENTIFIER));
+ assertEquals("uuid:879da420-1624-11da-bed9-84d13db13902",
identifierPart.getText());
+
+ OMElement msgNumberPart = sequencePart.getFirstChildWithName(
+ new QName
(Constants.WSRM.NS_URI_RM,Constants.WSRM.MSG_NUMBER));
+ assertEquals(1, Long.parseLong(msgNumberPart.getText()));
+ }
+}
Added:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/TerminateSequenceTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/TerminateSequenceTest.java?rev=329750&view=auto
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/TerminateSequenceTest.java
(added)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/wsrm/TerminateSequenceTest.java
Sun Oct 30 21:21:13 2005
@@ -0,0 +1,47 @@
+package org.apache.sandesha2.wsrm;
+
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.sandesha2.Constants;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.om.OMElement;
+
+import javax.xml.namespace.QName;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: sanka
+ * Date: Oct 7, 2005
+ * Time: 3:36:59 AM
+ * To change this template use File | Settings | File Templates.
+ */
+public class TerminateSequenceTest extends SandeshaTestCase {
+
+ public TerminateSequenceTest() {
+ super("TerminateSequenceTest");
+ }
+
+ public void testFromOMElement() {
+ TerminateSequence terminateSequence = new TerminateSequence();
+ SOAPEnvelope env = getSOAPEnvelope("", "TerminateSequence.xml");
+ terminateSequence.fromOMElement(env.getBody());
+
+ Identifier identifier = terminateSequence.getIdentifier();
+ assertEquals("uuid:59b0c910-1625-11da-bdfc-b09ed76a1f06",
identifier.getIdentifier());
+ }
+
+ public void testToSOAPEnvelope() {
+ TerminateSequence terminateSequence = new TerminateSequence();
+ Identifier identifier = new Identifier();
+ identifier.setIndentifer("uuid:59b0c910-1625-11da-bdfc-b09ed76a1f06");
+ terminateSequence.setIdentifier(identifier);
+
+ SOAPEnvelope env = getEmptySOAPEnvelope();
+ terminateSequence.toSOAPEnvelope(env);
+
+ OMElement terminateSeqPart = env.getBody().getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.TERMINATE_SEQUENCE));
+ OMElement identifierPart = terminateSeqPart.getFirstChildWithName(
+ new QName(Constants.WSRM.NS_URI_RM,
Constants.WSRM.IDENTIFIER));
+ assertEquals("uuid:59b0c910-1625-11da-bdfc-b09ed76a1f06",
identifierPart.getText());
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
