You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2007/01/11 01:42:45 UTC
svn commit: r495065 -
/incubator/servicemix/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
Author: gnodet
Date: Wed Jan 10 16:42:44 2007
New Revision: 495065
URL: http://svn.apache.org/viewvc?view=rev&rev=495065
Log:
Raise delays so that all tests are successful
Modified:
incubator/servicemix/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
Modified: incubator/servicemix/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java?view=diff&rev=495065&r1=495064&r2=495065
==============================================================================
--- incubator/servicemix/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java (original)
+++ incubator/servicemix/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java Wed Jan 10 16:42:44 2007
@@ -118,7 +118,7 @@
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
receiver.getMessageList().assertMessagesReceived(1);
NormalizedMessage msg = (NormalizedMessage) receiver.getMessageList().getMessages().get(0);
@@ -126,7 +126,7 @@
assertEquals("Notify", node.getLocalName());
// Wait for acks to be processed
- Thread.sleep(50);
+ Thread.sleep(150);
}
public void testRawNotify() throws Exception {
@@ -142,7 +142,7 @@
// END SNIPPET: notify
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
receiver.getMessageList().assertMessagesReceived(1);
NormalizedMessage msg = (NormalizedMessage) receiver.getMessageList().getMessages().get(0);
@@ -150,7 +150,7 @@
assertEquals("hello", node.getLocalName());
// Wait for acks to be processed
- Thread.sleep(50);
+ Thread.sleep(150);
}
public void testUnsubscribe() throws Exception {
@@ -161,7 +161,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
assertEquals(1, pullPoint.getMessages(0).size());
@@ -169,12 +169,12 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
assertEquals(0, pullPoint.getMessages(0).size());
// Wait for acks to be processed
- Thread.sleep(50);
+ Thread.sleep(150);
}
public void testPauseResume() throws Exception {
@@ -183,7 +183,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
assertEquals(1, pullPoint.getMessages(0).size());
@@ -191,7 +191,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
assertEquals(0, pullPoint.getMessages(0).size());
@@ -199,12 +199,12 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
assertEquals(1, pullPoint.getMessages(0).size());
// Wait for acks to be processed
- Thread.sleep(50);
+ Thread.sleep(150);
}
public void testPull() throws Exception {
@@ -213,14 +213,14 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
List<NotificationMessageHolderType> msgs = pullPoint.getMessages(0);
assertNotNull(msgs);
assertEquals(1, msgs.size());
// Wait for acks to be processed
- Thread.sleep(50);
+ Thread.sleep(150);
}
public void testPullWithFilter() throws Exception {
@@ -259,7 +259,7 @@
publisherComponent.setDemand(true);
jbi.activateComponent(publisherComponent, "publisher");
- Thread.sleep(50);
+ Thread.sleep(150);
assertNull(publisherComponent.getSubscription());
PullPoint pullPoint = wsnCreatePullPoint.createPullPoint();
@@ -273,7 +273,7 @@
Thread.sleep(500);
assertNull(publisherComponent.getSubscription());
- Thread.sleep(50);
+ Thread.sleep(150);
}
public void testDeployPullPoint() throws Exception {
@@ -288,7 +288,7 @@
PullPoint pullPoint = new PullPoint(
AbstractWSAClient.createWSA("http://www.consumer.org/service/endpoint"),
jbi);
- Thread.sleep(50);
+ Thread.sleep(150);
assertEquals(1, pullPoint.getMessages(0).size());
}
@@ -309,7 +309,7 @@
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
receiver.getMessageList().assertMessagesReceived(1);
receiver.getMessageList().flushMessages();
@@ -317,14 +317,14 @@
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
assertEquals(0, receiver.getMessageList().flushMessages().size());
wsnComponent.getServiceUnitManager().start("subscription");
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(50);
+ Thread.sleep(150);
receiver.getMessageList().assertMessagesReceived(1);
receiver.getMessageList().flushMessages();
}