camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r618723 - in /activemq/camel/trunk/tests/camel-itest/src/test: java/org/apache/camel/itest/jms/JmsPerformanceTest.java resources/activemq.xml
Date Tue, 05 Feb 2008 17:55:51 GMT
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>
 



Mime
View raw message