Author: davsclaus
Date: Tue Oct 30 14:31:19 2012
New Revision: 1403718
URL: http://svn.apache.org/viewvc?rev=1403718&view=rev
Log:
CAMEL-5750: Fixed test
Modified:
camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaConsumerIdleMessageTest.java
Modified:
camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaConsumerIdleMessageTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaConsumerIdleMessageTest.java?rev=1403718&r1=1403717&r2=1403718&view=diff
==============================================================================
---
camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaConsumerIdleMessageTest.java
(original)
+++
camel/trunk/components/camel-jpa/src/test/java/org/apache/camel/component/jpa/JpaConsumerIdleMessageTest.java
Tue Oct 30 14:31:19 2012
@@ -29,11 +29,10 @@ public class JpaConsumerIdleMessageTest
@Test
public void testConsumeIdleMessages() throws Exception {
- Thread.sleep(290);
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMinimumMessageCount(2);
-
assertMockEndpointsSatisfied();
+
assertTrue(mock.getExchanges().get(0).getIn().getBody() == null);
assertTrue(mock.getExchanges().get(1).getIn().getBody() == null);
}
@@ -41,7 +40,7 @@ public class JpaConsumerIdleMessageTest
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
public void configure() throws Exception {
-
from("jpa://org.apache.camel.examples.MultiSteps?consumer.nativeQuery=select *
from MultiSteps where step = 1"
+
from("jpa://org.apache.camel.examples.MultiSteps?consumer.nativeQuery=select *
from MultiSteps where step = 999"
+ "&delay=100&sendEmptyMessageWhenIdle=true")
.to("mock:result");
}