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 2008/06/10 13:18:50 UTC
svn commit: r666065 -
/servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
Author: gnodet
Date: Tue Jun 10 04:18:49 2008
New Revision: 666065
URL: http://svn.apache.org/viewvc?rev=666065&view=rev
Log:
Raise timeouts to avoid hanging tests
Modified:
servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
Modified: servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java?rev=666065&r1=666064&r2=666065&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java (original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java Tue Jun 10 04:18:49 2008
@@ -120,7 +120,7 @@
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
receiver.getMessageList().assertMessagesReceived(1);
NormalizedMessage msg = (NormalizedMessage) receiver.getMessageList().getMessages().get(0);
@@ -128,7 +128,7 @@
assertEquals("Notify", node.getLocalName());
// Wait for acks to be processed
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void testRawNotify() throws Exception {
@@ -144,7 +144,7 @@
// END SNIPPET: notify
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
receiver.getMessageList().assertMessagesReceived(1);
NormalizedMessage msg = (NormalizedMessage) receiver.getMessageList().getMessages().get(0);
@@ -152,7 +152,7 @@
assertEquals("hello", node.getLocalName());
// Wait for acks to be processed
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void testUnsubscribe() throws Exception {
@@ -163,7 +163,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(1, pullPoint.getMessages(0).size());
@@ -171,12 +171,12 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(0, pullPoint.getMessages(0).size());
// Wait for acks to be processed
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void testPauseResume() throws Exception {
@@ -185,7 +185,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(1, pullPoint.getMessages(0).size());
@@ -193,7 +193,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(0, pullPoint.getMessages(0).size());
@@ -201,12 +201,12 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(1, pullPoint.getMessages(0).size());
// Wait for acks to be processed
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void testPull() throws Exception {
@@ -215,14 +215,14 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
List<NotificationMessageHolderType> msgs = pullPoint.getMessages(0);
assertNotNull(msgs);
assertEquals(1, msgs.size());
// Wait for acks to be processed
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void xtestPullWithFilter() throws Exception {
@@ -261,7 +261,7 @@
publisherComponent.setDemand(true);
jbi.activateComponent(publisherComponent, "publisher");
- Thread.sleep(150);
+ Thread.sleep(500);
assertNull(publisherComponent.getSubscription());
PullPoint pullPoint = wsnCreatePullPoint.createPullPoint();
@@ -275,7 +275,7 @@
Thread.sleep(500);
assertNull(publisherComponent.getSubscription());
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void testDeployPullPoint() throws Exception {
@@ -290,7 +290,7 @@
PullPoint pullPoint = new PullPoint(
AbstractWSAClient.createWSA("http://www.consumer.org/service/endpoint"),
jbi);
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(1, pullPoint.getMessages(0).size());
}
@@ -311,7 +311,7 @@
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
receiver.getMessageList().assertMessagesReceived(1);
receiver.getMessageList().flushMessages();
@@ -319,14 +319,14 @@
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(0, receiver.getMessageList().flushMessages().size());
wsnComponent.getServiceUnitManager().start("subscription");
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
receiver.getMessageList().assertMessagesReceived(1);
receiver.getMessageList().flushMessages();
}