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/03/17 06:03:56 UTC
svn commit: r386540 - in
/webservices/sandesha/trunk/test/src/org/apache/sandesha2:
AddressablePingTest.java AnonymousPingTest.java
Author: chamikara
Date: Thu Mar 16 21:03:55 2006
New Revision: 386540
URL: http://svn.apache.org/viewcvs?rev=386540&view=rev
Log:
Updates to test cases
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/AddressablePingTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/AnonymousPingTest.java
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/AddressablePingTest.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/AddressablePingTest.java?rev=386540&r1=386539&r2=386540&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/AddressablePingTest.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/AddressablePingTest.java Thu Mar 16 21:03:55 2006
@@ -110,21 +110,36 @@
clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
+ SequenceReport sequenceReport = null;
+ boolean complete = false;
+ while (!complete) {
+ sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(to,sequenceKey,configContext);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ Sandesha2ClientAPI.terminateSequence(to,sequenceKey,serviceClient,configContext);
+ serviceClient.finalizeInvoke();
+
try {
- //waiting till the messages exchange finishes.
- Thread.sleep(10000);
+ Thread.sleep(1000);
} catch (InterruptedException e) {
- throw new SandeshaException ("sleep interupted");
+ e.printStackTrace();
}
- SequenceReport sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(to,sequenceKey,configContext);
+ sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(to,sequenceKey,configContext);
assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
assertTrue(sequenceReport.getCompletedMessages().contains(new Long(2)));
assertTrue(sequenceReport.getCompletedMessages().contains(new Long(3)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
-
- serviceClient.finalizeInvoke();
}
Modified: webservices/sandesha/trunk/test/src/org/apache/sandesha2/AnonymousPingTest.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/AnonymousPingTest.java?rev=386540&r1=386539&r2=386540&view=diff
==============================================================================
--- webservices/sandesha/trunk/test/src/org/apache/sandesha2/AnonymousPingTest.java (original)
+++ webservices/sandesha/trunk/test/src/org/apache/sandesha2/AnonymousPingTest.java Thu Mar 16 21:03:55 2006
@@ -104,21 +104,37 @@
clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
+ SequenceReport sequenceReport = null;
+ boolean complete = false;
+ while (!complete) {
+ sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(to,sequenceKey,configContext);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ Sandesha2ClientAPI.terminateSequence(to,sequenceKey,serviceClient,configContext);
+ serviceClient.finalizeInvoke();
+
try {
- //waiting till the messages exchange finishes.
- Thread.sleep(5000);
+ Thread.sleep(1000);
} catch (InterruptedException e) {
- throw new SandeshaException ("sleep interupted");
+ e.printStackTrace();
}
- SequenceReport sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(to,sequenceKey,configContext);
+ sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(to,sequenceKey,configContext);
assertTrue(sequenceReport.getCompletedMessages().contains(new Long(1)));
assertTrue(sequenceReport.getCompletedMessages().contains(new Long(2)));
assertTrue(sequenceReport.getCompletedMessages().contains(new Long(3)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
-
- serviceClient.finalizeInvoke();
+
}
private OMElement getPingOMBlock(String text) {
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org