You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ff...@apache.org on 2008/09/20 17:21:21 UTC
svn commit: r697379 -
/servicemix/components/bindings/servicemix-jms/trunk/src/test/java/org/apache/servicemix/jms/JmsConsumerEndpointTest.java
Author: ffang
Date: Sat Sep 20 08:21:20 2008
New Revision: 697379
URL: http://svn.apache.org/viewvc?rev=697379&view=rev
Log:
[SM-1588]JmsConsumerEndpointTest hang on some linux box
Modified:
servicemix/components/bindings/servicemix-jms/trunk/src/test/java/org/apache/servicemix/jms/JmsConsumerEndpointTest.java
Modified: servicemix/components/bindings/servicemix-jms/trunk/src/test/java/org/apache/servicemix/jms/JmsConsumerEndpointTest.java
URL: http://svn.apache.org/viewvc/servicemix/components/bindings/servicemix-jms/trunk/src/test/java/org/apache/servicemix/jms/JmsConsumerEndpointTest.java?rev=697379&r1=697378&r2=697379&view=diff
==============================================================================
--- servicemix/components/bindings/servicemix-jms/trunk/src/test/java/org/apache/servicemix/jms/JmsConsumerEndpointTest.java (original)
+++ servicemix/components/bindings/servicemix-jms/trunk/src/test/java/org/apache/servicemix/jms/JmsConsumerEndpointTest.java Sat Sep 20 08:21:20 2008
@@ -132,6 +132,7 @@
jmsTemplate.convertAndSend("destination", "<hello>world</hello>");
receiver.getMessageList().assertMessagesReceived(1);
+ Thread.sleep(500);
}
public void testDurableConsumerDefault() throws Exception {
@@ -149,10 +150,8 @@
endpoint.setCacheLevel(DefaultMessageListenerContainer.CACHE_CONNECTION);
component.setEndpoints(new JmsConsumerEndpoint[] {endpoint});
container.activateComponent(component, "servicemix-jms");
-
- container.start();
-
Thread.sleep(500);
+ container.start();
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(new PooledConnectionFactory(connectionFactory));
@@ -160,6 +159,7 @@
jmsTemplate.afterPropertiesSet();
jmsTemplate.convertAndSend("destinationTopic", "<hello>world</hello>");
receiver.getMessageList().assertMessagesReceived(1);
+ Thread.sleep(500);
}
public void testConsumerDefaultInOut() throws Exception {
@@ -181,6 +181,7 @@
Element e = sourceTransformer.toDOMElement(new StringSource(msg.getText()));
assertEquals("hello", e.getTagName());
assertEquals("world", e.getTextContent());
+ Thread.sleep(500);
}
public void testConsumerDefaultJmsTx() throws Exception {
@@ -198,6 +199,7 @@
jmsTemplate.convertAndSend("destination", "<hello>world</hello>");
receiver.getMessageList().assertMessagesReceived(1);
+ Thread.sleep(500);
}
public void testConsumerDefaultInOutJmsTx() throws Exception {
@@ -220,6 +222,7 @@
Element e = sourceTransformer.toDOMElement(new StringSource(msg.getText()));
assertEquals("hello", e.getTagName());
assertEquals("world", e.getTextContent());
+ Thread.sleep(500);
}
public void testConsumerDefaultXaTx() throws Exception {
@@ -237,6 +240,7 @@
jmsTemplate.convertAndSend("destination", "<hello>world</hello>");
receiver.getMessageList().assertMessagesReceived(1);
+ Thread.sleep(500);
}
public void testConsumerServer() throws Exception {