Author: chamikara
Date: Sun May 7 20:21:02 2006
New Revision: 404905
URL: http://svn.apache.org/viewcvs?rev=404905&view=rev
Log:
Updated test cases
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/MessageRetransmissionTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousAckEchoTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousPingTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/AddressingVersionTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/RMVersionTest.java
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/SOAPVersionTest.java
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/MessageRetransmissionTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/MessageRetransmissionTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/MessageRetransmissionTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/MessageRetransmissionTest.java
Sun May 7 20:21:02 2006
@@ -112,7 +112,7 @@
serviceClient.setOptions(clientOptions);
serviceClient.fireAndForget(getPingOMBlock("ping1"));
- serviceClient.fireAndForget(getPingOMBlock("ping2"));
+// serviceClient.fireAndForget(getPingOMBlock("ping2"));
//starting the server after a wait
Thread.sleep(10000);
@@ -120,10 +120,10 @@
startServer();
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
- serviceClient.fireAndForget(getPingOMBlock("ping3"));
+ serviceClient.fireAndForget(getPingOMBlock("ping2"));
- Thread.sleep(7000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaClientTest.java
Sun May 7 20:21:02 2006
@@ -119,7 +119,7 @@
SandeshaClient.createSequence(serviceClient,true);
- Thread.sleep(3000);
+ Thread.sleep(15000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SandeshaReportsTest.java
Sun May 7 20:21:02 2006
@@ -142,7 +142,7 @@
serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo2",sequenceKey),callback2);
- Thread.sleep(10000);
+ Thread.sleep(45000);
//testing outgoing sequence reports
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
@@ -203,7 +203,7 @@
try {
//waiting till the messages exchange finishes.
- Thread.sleep(12000);
+ Thread.sleep(18000);
} catch (InterruptedException e) {
throw new SandeshaException ("sleep interupted");
}
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/SquenceOfferTest.java
Sun May 7 20:21:02 2006
@@ -135,27 +135,21 @@
serviceClient.setOptions(clientOptions);
- TestCallback callback1 = new TestCallback ("Callback 1");
-
serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo1",sequenceKey),callback1);
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
- TestCallback callback2 = new TestCallback ("Callback 2");
- serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo2",sequenceKey),callback2);
-
+ TestCallback callback1 = new TestCallback ("Callback 1");
+ serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo1",sequenceKey),callback1);
- Thread.sleep(12000);
+ Thread.sleep(22000);
//assertions for the out sequence.
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
- assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(2)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
assertTrue(callback1.isComplete());
- assertTrue(callback2.isComplete());
assertEquals(callback1.getResult(),"echo1");
- assertEquals(callback2.getResult(),"echo1echo2");
//checking weather the incomingSequenceReport has the offered
sequence ID
SandeshaReport rmReport =
SandeshaClient.getSandeshaReport(configContext);
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
Sun May 7 20:21:02 2006
@@ -116,27 +116,22 @@
serviceClient.setOptions(clientOptions);
- TestCallback callback1 = new TestCallback ("Callback 1");
-
serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo1",sequenceKey),callback1);
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
- TestCallback callback2 = new TestCallback ("Callback 2");
- serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo2",sequenceKey),callback2);
+ TestCallback callback1 = new TestCallback ("Callback 1");
+ serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo1",sequenceKey),callback1);
- Thread.sleep(12000);
+ Thread.sleep(40000);
//assertions for the out sequence.
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
- assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(2)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
assertTrue(callback1.isComplete());
- assertTrue(callback2.isComplete());
assertEquals(callback1.getResult(),"echo1");
- assertEquals(callback2.getResult(),"echo1echo2");
serviceClient.finalizeInvoke();
}
@@ -174,27 +169,22 @@
serviceClient.setOptions(clientOptions);
- TestCallback callback1 = new TestCallback ("Callback 1");
-
serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo1",sequenceKey),callback1);
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
- TestCallback callback2 = new TestCallback ("Callback 2");
- serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo2",sequenceKey),callback2);
+ TestCallback callback1 = new TestCallback ("Callback 1");
+ serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo1",sequenceKey),callback1);
- Thread.sleep(12000);
+ Thread.sleep(40000);
//assertions for the out sequence.
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
- assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(2)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
assertTrue(callback1.isComplete());
- assertTrue(callback2.isComplete());
assertEquals(callback1.getResult(),"echo1");
- assertEquals(callback2.getResult(),"echo1echo2");
serviceClient.finalizeInvoke();
}
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java
Sun May 7 20:21:02 2006
@@ -126,21 +126,18 @@
//serviceClient.
serviceClient.setOptions(clientOptions);
-
- serviceClient.fireAndForget(getPingOMBlock("ping1"));
-
+
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
serviceClient.fireAndForget(getPingOMBlock("ping2"));
try {
- Thread.sleep(7000);
+ Thread.sleep(30000);
} catch (InterruptedException e) {
e.printStackTrace();
}
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
- assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(2)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousAckEchoTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousAckEchoTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousAckEchoTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousAckEchoTest.java
Sun May 7 20:21:02 2006
@@ -114,25 +114,20 @@
serviceClient.setOptions(clientOptions);
- TestCallback callback1 = new TestCallback ("Callback 1");
-
serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo1",sequenceKey),callback1);
-
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
- TestCallback callback2 = new TestCallback ("Callback 2");
- serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo2",sequenceKey),callback2);
+ TestCallback callback1 = new TestCallback ("Callback 1");
+ serviceClient.sendReceiveNonBlocking
(getEchoOMBlock("echo1",sequenceKey),callback1);
- Thread.sleep(10000);
+ Thread.sleep(40000);
//assertions for the out sequence.
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
- assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(2)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
assertEquals(callback1.getResult(),"echo1");
- assertEquals(callback2.getResult(),"echo1echo2");
serviceClient.finalizeInvoke();
}
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousPingTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousPingTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousPingTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/scenarios/AnonymousPingTest.java
Sun May 7 20:21:02 2006
@@ -120,17 +120,13 @@
serviceClient.setOptions(clientOptions);
- serviceClient.fireAndForget(getPingOMBlock("ping1"));
- serviceClient.fireAndForget(getPingOMBlock("ping2"));
-
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
- serviceClient.fireAndForget(getPingOMBlock("ping3"));
+ serviceClient.fireAndForget(getPingOMBlock("ping1"));
- Thread.sleep(5000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
- assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(2)));
assertEquals(sequenceReport.getSequenceStatus(),SequenceReport.SEQUENCE_STATUS_TERMINATED);
assertEquals(sequenceReport.getSequenceDirection(),SequenceReport.SEQUENCE_DIRECTION_OUT);
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/AddressingVersionTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/AddressingVersionTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/AddressingVersionTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/AddressingVersionTest.java
Sun May 7 20:21:02 2006
@@ -108,7 +108,7 @@
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
- Thread.sleep(7000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
@@ -149,7 +149,7 @@
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
- Thread.sleep(7000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/RMVersionTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/RMVersionTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/RMVersionTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/RMVersionTest.java
Sun May 7 20:21:02 2006
@@ -98,7 +98,7 @@
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
//setting the addressing version as submission
-
clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.WSRM);
+
clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_0);
ServiceClient serviceClient = new ServiceClient
(configContext,null);
//serviceClient.
@@ -108,7 +108,7 @@
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
- Thread.sleep(5000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
@@ -139,7 +139,7 @@
clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
//setting the RM version as OASIS.
-
clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.WSRX);
+
clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1);
ServiceClient serviceClient = new ServiceClient
(configContext,null);
//serviceClient.
@@ -149,7 +149,7 @@
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
- Thread.sleep(5000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
Modified:
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/SOAPVersionTest.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/SOAPVersionTest.java?rev=404905&r1=404904&r2=404905&view=diff
==============================================================================
---
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/SOAPVersionTest.java
(original)
+++
webservices/sandesha/trunk/test/src/org/apache/sandesha2/versions/SOAPVersionTest.java
Sun May 7 20:21:02 2006
@@ -106,7 +106,7 @@
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
- Thread.sleep(5000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
@@ -146,7 +146,7 @@
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
serviceClient.fireAndForget(getPingOMBlock("ping3"));
- Thread.sleep(5000);
+ Thread.sleep(10000);
SequenceReport sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
assertTrue(sequenceReport.getCompletedMessages().contains(new
Long(1)));
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
