CAMEL-7177: Use non clustered vertx by default.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3a391332 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3a391332 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3a391332 Branch: refs/heads/camel-2.12.x Commit: 3a391332a0bc742f2205cc698e9d105607385bf3 Parents: 5be23c0 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Feb 7 17:24:58 2014 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Feb 7 17:25:24 2014 +0100 ---------------------------------------------------------------------- .../apache/camel/component/vertx/VertxComponent.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3a391332/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java index 57ad087..4074b2b 100644 --- a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java +++ b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxComponent.java @@ -35,8 +35,8 @@ import org.vertx.java.core.VertxFactory; public class VertxComponent extends UriEndpointComponent implements EndpointCompleter { private static final Logger LOG = LoggerFactory.getLogger(VertxComponent.class); private Vertx vertx; - private String host = "127.0.0.1"; - private int port = 5701; + private String host; + private int port; public VertxComponent() { super(VertxEndpoint.class); @@ -88,10 +88,13 @@ public class VertxComponent extends UriEndpointComponent implements EndpointComp if (vertx == null) { // lets using a host / port if a host name is specified if (host != null && host.length() > 0) { - LOG.debug("Creating Vertx {}:{}", host, port); + LOG.info("Creating Clustered Vertx {}:{}", host, port); vertx = VertxFactory.newVertx(port, host); + } else if (host != null) { + LOG.info("Creating Clustered Vertx {}", host); + vertx = VertxFactory.newVertx(host); } else { - LOG.debug("Creating Vertx"); + LOG.info("Creating Non-Clustered Vertx"); vertx = VertxFactory.newVertx(); } } @@ -101,7 +104,7 @@ public class VertxComponent extends UriEndpointComponent implements EndpointComp protected void doStop() throws Exception { super.doStop(); - LOG.debug("Stopping Vertx {}", vertx); + LOG.info("Stopping Vertx {}", vertx); vertx.stop(); } }