You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2011/08/14 11:26:55 UTC
svn commit: r1157503 - in /camel/trunk:
camel-core/src/test/java/org/apache/camel/component/test/TestEndpointTest.java
components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/SharedPersistentQueueMessageListenerContainer.java
Author: davsclaus
Date: Sun Aug 14 09:26:55 2011
New Revision: 1157503
URL: http://svn.apache.org/viewvc?rev=1157503&view=rev
Log:
Fixed test on CI server. Polished.
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/component/test/TestEndpointTest.java
camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/SharedPersistentQueueMessageListenerContainer.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/test/TestEndpointTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/test/TestEndpointTest.java?rev=1157503&r1=1157502&r2=1157503&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/test/TestEndpointTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/test/TestEndpointTest.java Sun Aug 14 09:26:55 2011
@@ -25,10 +25,8 @@ import org.apache.camel.builder.RouteBui
public class TestEndpointTest extends ContextTestSupport {
public void testMocksAreValid() throws Exception {
- // perform the test, and send in 2 messages we expect
- Thread.sleep(500);
+ // now run the test and send in the message which we would expect
template.sendBody("seda:foo", "Hello World");
- template.sendBody("seda:foo", "Bye World");
assertMockEndpointsSatisfied();
}
@@ -38,9 +36,8 @@ public class TestEndpointTest extends Co
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- // send 2 bodies to the seda:foo which is the messages we expect
+ // send 1 body to the seda:foo which is the messages we expect
template.sendBody("seda:foo", "Hello World");
- template.sendBody("seda:foo", "Bye World");
from("seda:foo")
.to("test:seda:foo");
Modified: camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/SharedPersistentQueueMessageListenerContainer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/SharedPersistentQueueMessageListenerContainer.java?rev=1157503&r1=1157502&r2=1157503&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/SharedPersistentQueueMessageListenerContainer.java (original)
+++ camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/SharedPersistentQueueMessageListenerContainer.java Sun Aug 14 09:26:55 2011
@@ -27,6 +27,8 @@ import org.springframework.jms.listener.
* designated reply messages from the shared queue. Since the queue is shared, then we can only
* pickup the reply messages which is intended for us, so to support that we must use JMS
* Message Selectors.
+ * <p/>
+ * See more details at <a href="http://camel.apache.org/jms">camel-jms</a>.
*
* @see ExclusivePersistentQueueMessageListenerContainer
*/