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 ch...@apache.org on 2006/07/31 02:12:57 UTC
svn commit: r426984 -
/webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
Author: chamikara
Date: Sun Jul 30 17:12:56 2006
New Revision: 426984
URL: http://svn.apache.org/viewvc?rev=426984&view=rev
Log:
Iproved the AddressableEchoTest to do tests on the IncomingSequenceReports
Modified:
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
Modified: webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java?rev=426984&r1=426983&r2=426984&view=diff
==============================================================================
--- webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java (original)
+++ webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java Sun Jul 30 17:12:56 2006
@@ -1,11 +1,10 @@
package org.apache.sandesha2.scenarios;
import java.io.File;
+import java.util.ArrayList;
import javax.xml.namespace.QName;
-import junit.framework.TestCase;
-
import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
@@ -118,23 +117,47 @@
serviceClient.setOptions(clientOptions);
-
- clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
TestCallback callback1 = new TestCallback ("Callback 1");
serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo1",sequenceKey),callback1);
+
+ TestCallback callback2 = new TestCallback ("Callback 2");
+ serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo2",sequenceKey),callback2);
+
+ clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
+ TestCallback callback3 = new TestCallback ("Callback 3");
+ serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo3",sequenceKey),callback3);
Thread.sleep(40000);
//assertions for the out sequence.
- SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
- assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
- assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
- assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
+ SequenceReport outgoingSequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ assertEquals (outgoingSequenceReport.getCompletedMessages().size(),3);
+ assertTrue(outgoingSequenceReport.getCompletedMessages().contains(new Long(1)));
+ assertTrue(outgoingSequenceReport.getCompletedMessages().contains(new Long(2)));
+ assertTrue(outgoingSequenceReport.getCompletedMessages().contains(new Long(3)));
+ assertEquals(outgoingSequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
+ assertEquals(outgoingSequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
+
+ ArrayList incomingReports = SandeshaClient.getIncomingSequenceReports(configContext);
+ assertEquals(incomingReports.size(),1);
+ SequenceReport incomingSequenceReport = (SequenceReport) incomingReports.get(0);
+ assertEquals (incomingSequenceReport.getCompletedMessages().size(),3);
+ assertTrue(incomingSequenceReport.getCompletedMessages().contains(new Long(1)));
+ assertTrue(incomingSequenceReport.getCompletedMessages().contains(new Long(2)));
+ assertTrue(incomingSequenceReport.getCompletedMessages().contains(new Long(3)));
+ assertEquals(incomingSequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
+ assertEquals(incomingSequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_IN);
assertTrue(callback1.isComplete());
assertEquals(callback1.getResult(),"echo1");
+ assertTrue(callback2.isComplete());
+ assertEquals(callback2.getResult(),"echo1echo2");
+
+ assertTrue(callback3.isComplete());
+ assertEquals(callback3.getResult(),"echo1echo2echo3");
+
serviceClient.finalizeInvoke();
}
@@ -174,21 +197,45 @@
serviceClient.setOptions(clientOptions);
- clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
TestCallback callback1 = new TestCallback ("Callback 1");
serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo1",sequenceKey),callback1);
+
+ TestCallback callback2 = new TestCallback ("Callback 2");
+ serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo2",sequenceKey),callback2);
+
+ clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
+ TestCallback callback3 = new TestCallback ("Callback 3");
+ serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo3",sequenceKey),callback3);
Thread.sleep(40000);
//assertions for the out sequence.
- SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
- assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
- assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
- assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
+ //assertions for the out sequence.
+ SequenceReport outgoingSequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ assertEquals (outgoingSequenceReport.getCompletedMessages().size(),3);
+ assertTrue(outgoingSequenceReport.getCompletedMessages().contains(new Long(1)));
+ assertTrue(outgoingSequenceReport.getCompletedMessages().contains(new Long(2)));
+ assertTrue(outgoingSequenceReport.getCompletedMessages().contains(new Long(3)));
+ assertEquals(outgoingSequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
+ assertEquals(outgoingSequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
+
+ SequenceReport incomingSequenceReport = SandeshaClient.getIncomingSequenceReport(offeredSequeiceId,configContext);
+ assertEquals (incomingSequenceReport.getCompletedMessages().size(),3);
+ assertTrue(incomingSequenceReport.getCompletedMessages().contains(new Long(1)));
+ assertTrue(incomingSequenceReport.getCompletedMessages().contains(new Long(2)));
+ assertTrue(incomingSequenceReport.getCompletedMessages().contains(new Long(3)));
+ assertEquals(incomingSequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
+ assertEquals(incomingSequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_IN);
assertTrue(callback1.isComplete());
assertEquals(callback1.getResult(),"echo1");
+
+ assertTrue(callback2.isComplete());
+ assertEquals(callback2.getResult(),"echo1echo2");
+
+ assertTrue(callback3.isComplete());
+ assertEquals(callback3.getResult(),"echo1echo2echo3");
serviceClient.finalizeInvoke();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org