camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bvah...@apache.org
Subject svn commit: r1416246 - in /camel/trunk: camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperEndpointTest.java
Date Sun, 02 Dec 2012 20:21:28 GMT
Author: bvahdat
Date: Sun Dec  2 20:21:27 2012
New Revision: 1416246

URL: http://svn.apache.org/viewvc?rev=1416246&view=rev
Log:
Polished.

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
    camel/trunk/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperEndpointTest.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java?rev=1416246&r1=1416245&r2=1416246&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java Sun
Dec  2 20:21:27 2012
@@ -1878,9 +1878,9 @@ public class DefaultCamelContext extends
     protected void logRouteState(Route route, String state) {
         if (log.isInfoEnabled()) {
             if (route.getConsumer() != null) {
-                log.info("Route: {} {}, was consuming from: {}", new Object[]{route.getId(),
state, route.getConsumer().getEndpoint()});
+                log.info("Route: {} is {}, was consuming from: {}", new Object[]{route.getId(),
state, route.getConsumer().getEndpoint()});
             } else {
-                log.info("Route: {} {}.", route.getId(), state);
+                log.info("Route: {} is {}.", route.getId(), state);
             }
         }
     }
@@ -1888,7 +1888,7 @@ public class DefaultCamelContext extends
     protected synchronized void stopRouteService(RouteService routeService) throws Exception
{
         routeService.stop();
         for (Route route : routeService.getRoutes()) {
-            logRouteState(route, "stoped");
+            logRouteState(route, "stopped");
         }
     }
 

Modified: camel/trunk/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperEndpointTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperEndpointTest.java?rev=1416246&r1=1416245&r2=1416246&view=diff
==============================================================================
--- camel/trunk/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperEndpointTest.java
(original)
+++ camel/trunk/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/ZooKeeperEndpointTest.java
Sun Dec  2 20:21:27 2012
@@ -24,7 +24,7 @@ public class ZooKeeperEndpointTest exten
     @Test
     public void awaitExistenceOptionOnEndpoint() {
         ZooKeeperEndpoint endpoint = context.getEndpoint("zookeeper:someserver/zoo", ZooKeeperEndpoint.class);
-        assertTrue("The awaitExistence option defaults to true", endpoint.getAwaitExistence());
+        assertTrue("The awaitExistence option should default to true", endpoint.getAwaitExistence());
 
         endpoint = context.getEndpoint("zookeeper:someserver/zoo?awaitExistence=true", ZooKeeperEndpoint.class);
         assertTrue("The awaitExistence option should be true", endpoint.getAwaitExistence());



Mime
View raw message