Repository: camel Updated Branches: refs/heads/master a1e92a054 -> 58f6c460d
CAMEL-9803: Camel-NATS: Switch to Jnats client as Java_nats is deprecated Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/58f6c460 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/58f6c460 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/58f6c460 Branch: refs/heads/master Commit: 58f6c460d544b72e1d13a8f7f009851633215318 Parents: a1e92a0 Author: Andrea Cosentino <[email protected]> Authored: Sun Apr 3 13:59:36 2016 +0200 Committer: Andrea Cosentino <[email protected]> Committed: Sun Apr 3 13:59:36 2016 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/nats/NatsConfiguration.java | 9 +-------- .../camel/component/nats/NatsPropertiesConstants.java | 2 +- 2 files changed, 2 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/58f6c460/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java ---------------------------------------------------------------------- diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java index 1618eb9..53a7638 100644 --- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java +++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConfiguration.java @@ -206,7 +206,7 @@ public class NatsConfiguration { public Properties createProperties() { Properties props = new Properties(); - addPropertyIfNotNull(props, NatsPropertiesConstants.NATS_PROPERTY_URI, splitServers()); + addPropertyIfNotNull(props, NatsPropertiesConstants.NATS_PROPERTY_URL, splitServers()); addPropertyIfNotNull(props, NatsPropertiesConstants.NATS_PROPERTY_VERBOSE, getVerbose()); addPropertyIfNotNull(props, NatsPropertiesConstants.NATS_PROPERTY_PEDANTIC, getPedantic()); addPropertyIfNotNull(props, NatsPropertiesConstants.NATS_PROPERTY_SSL, getSsl()); @@ -218,13 +218,6 @@ public class NatsConfiguration { return props; } -// public Properties createSubProperties() { -// Properties props = new Properties(); -// addPropertyIfNotNull(props, NatsPropertiesConstants.NATS_PROPERTY_QUEUE, getQueueName()); -// addPropertyIfNotNull(props, NatsPropertiesConstants.NATS_PROPERTY_MAX_MESSAGES, getMaxMessages()); -// return props; -// } - private String splitServers() { StringBuilder servers = new StringBuilder(); String prefix = "nats://"; http://git-wip-us.apache.org/repos/asf/camel/blob/58f6c460/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsPropertiesConstants.java ---------------------------------------------------------------------- diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsPropertiesConstants.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsPropertiesConstants.java index 2e09361..61e5431 100644 --- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsPropertiesConstants.java +++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsPropertiesConstants.java @@ -17,7 +17,7 @@ package org.apache.camel.component.nats; public interface NatsPropertiesConstants { - String NATS_PROPERTY_URI = "uri"; + String NATS_PROPERTY_URL = "io.nats.client.url"; String NATS_PROPERTY_VERBOSE = "io.nats.client.verbose"; String NATS_PROPERTY_PEDANTIC = "io.nats.client.pedantic"; String NATS_PROPERTY_RECONNECT = "io.nats.client.reconnect.allowed";
