Author: cmueller Date: Sat Sep 22 20:57:32 2012 New Revision: 1388897 URL: http://svn.apache.org/viewvc?rev=1388897&view=rev Log: fixed test which failed sometimes on the CI server
Modified: camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartCleanupTest.java camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java Modified: camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartCleanupTest.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartCleanupTest.java?rev=1388897&r1=1388896&r2=1388897&view=diff ============================================================================== --- camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartCleanupTest.java (original) +++ camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartCleanupTest.java Sat Sep 22 20:57:32 2012 @@ -53,12 +53,12 @@ public class ManagedRouteStopAndStartCle Long completed = (Long) mbeanServer.getAttribute(on, "ExchangesCompleted"); assertEquals(1, completed.longValue()); - // should be 1 consumer and 1 processor + // should be 1 consumer and 2 processors Set<ObjectName> set = mbeanServer.queryNames(new ObjectName("*:type=consumers,*"), null); assertEquals("Should be 1 consumer", 1, set.size()); set = mbeanServer.queryNames(new ObjectName("*:type=processors,*"), null); - assertEquals("Should be 1 processor", 1, set.size()); + assertEquals("Should be 2 processors", 2, set.size()); // stop log.info(">>>>>>>>>>>>>>>>>> invoking stop <<<<<<<<<<<<<<<<<<<<<"); @@ -102,7 +102,7 @@ public class ManagedRouteStopAndStartCle assertEquals("Should be 1 consumer", 1, set.size()); set = mbeanServer.queryNames(new ObjectName("*:type=processors,*"), null); - assertEquals("Should be 1 processor", 1, set.size()); + assertEquals("Should be 2 processors", 2, set.size()); // this time the file is consumed mock.assertIsSatisfied(); Modified: camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java?rev=1388897&r1=1388896&r2=1388897&view=diff ============================================================================== --- camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java (original) +++ camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedRouteStopAndStartTest.java Sat Sep 22 20:57:32 2012 @@ -93,7 +93,9 @@ public class ManagedRouteStopAndStartTes return new RouteBuilder() { @Override public void configure() throws Exception { - from("file://target/managed").to("mock:result"); + from("file://target/managed") + .convertBodyTo(String.class) + .to("mock:result"); } }; }