You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by js...@apache.org on 2008/02/05 18:55:51 UTC
svn commit: r618723 - in /activemq/camel/trunk/tests/camel-itest/src/test:
java/org/apache/camel/itest/jms/JmsPerformanceTest.java
resources/activemq.xml
Author: jstrachan
Date: Tue Feb 5 09:55:43 2008
New Revision: 618723
URL: http://svn.apache.org/viewvc?rev=618723&view=rev
Log:
fixed up failing test case :)
Modified:
activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsPerformanceTest.java
activemq/camel/trunk/tests/camel-itest/src/test/resources/activemq.xml
Modified: activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsPerformanceTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsPerformanceTest.java?rev=618723&r1=618722&r2=618723&view=diff
==============================================================================
--- activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsPerformanceTest.java (original)
+++ activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsPerformanceTest.java Tue Feb 5 09:55:43 2008
@@ -38,7 +38,8 @@
protected long consumerSleep = 0L;
protected int expectedMessageCount;
protected ClassPathXmlApplicationContext applicationContext;
- protected boolean useLocalBroker;
+ protected boolean useLocalBroker = true;
+ private int consumedMessageCount;
public void testSendingAndReceivingMessages() throws Exception {
setExpectedMessageCount(messageCount);
@@ -73,7 +74,9 @@
}
protected void assertExpectedMessagesReceived() throws InterruptedException {
- assertTrue("The message ware received by the Pojo", receivedCountDown.await(50000, TimeUnit.SECONDS));
+ receivedCountDown.await(50000, TimeUnit.SECONDS);
+
+ assertEquals("Received message count", expectedMessageCount, consumedMessageCount);
// TODO assert that messages are received in order
}
@@ -132,6 +135,7 @@
}
}
receivedCountDown.countDown();
+ consumedMessageCount++;
}
}
}
Modified: activemq/camel/trunk/tests/camel-itest/src/test/resources/activemq.xml
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/tests/camel-itest/src/test/resources/activemq.xml?rev=618723&r1=618722&r2=618723&view=diff
==============================================================================
--- activemq/camel/trunk/tests/camel-itest/src/test/resources/activemq.xml (original)
+++ activemq/camel/trunk/tests/camel-itest/src/test/resources/activemq.xml Tue Feb 5 09:55:43 2008
@@ -24,11 +24,9 @@
<broker xmlns="http://activemq.org/config/1.0" dataDirectory="target/activemq">
-<!--
<transportConnectors>
<transportConnector name="openwire" uri="tcp://localhost:61616"/>
</transportConnectors>
--->
</broker>