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());