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:13:52 UTC
svn commit: r666063 -
/servicemix/smx3/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
Author: gnodet
Date: Tue Jun 10 04:13:52 2008
New Revision: 666063
URL: http://svn.apache.org/viewvc?rev=666063&view=rev
Log:
Raise timeouts to try fixing some handing tests
Modified:
servicemix/smx3/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
Modified: servicemix/smx3/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java?rev=666063&r1=666062&r2=666063&view=diff
==============================================================================
--- servicemix/smx3/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java (original)
+++ servicemix/smx3/trunk/deployables/serviceengines/servicemix-wsn2005/src/test/java/org/apache/servicemix/wsn/component/WSNComponentTest.java Tue Jun 10 04:13:52 2008
@@ -119,7 +119,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);
@@ -127,7 +127,7 @@
assertEquals("Notify", node.getLocalName());
// Wait for acks to be processed
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void testRawNotify() throws Exception {
@@ -143,7 +143,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);
@@ -151,7 +151,7 @@
assertEquals("hello", node.getLocalName());
// Wait for acks to be processed
- Thread.sleep(150);
+ Thread.sleep(500);
}
public void testUnsubscribe() throws Exception {
@@ -162,7 +162,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(1, pullPoint.getMessages(0).size());
@@ -170,12 +170,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 {
@@ -184,7 +184,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(1, pullPoint.getMessages(0).size());
@@ -192,7 +192,7 @@
wsnBroker.notify("myTopic", new Notify());
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
assertEquals(0, pullPoint.getMessages(0).size());
@@ -200,12 +200,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 {
@@ -214,14 +214,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 testPullWithFilter() throws Exception {
@@ -289,7 +289,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());
}
@@ -310,7 +310,7 @@
wsnBroker.notify("myTopic", parse("<hello>world</hello>"));
// Wait for notification
- Thread.sleep(150);
+ Thread.sleep(500);
receiver.getMessageList().assertMessagesReceived(1);
receiver.getMessageList().flushMessages();
@@ -318,14 +318,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();
}