You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2014/02/07 17:24:31 UTC
[2/2] git commit: CAMEL-7177: Use non clustered vertx by default.
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 <da...@apache.org>
Authored: Fri Feb 7 17:24:58 2014 +0100
Committer: Claus Ibsen <da...@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();
}
}