You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2016/04/03 14:00:33 UTC
camel git commit: CAMEL-9803: Camel-NATS: Switch to Jnats client as
Java_nats is deprecated
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 <an...@gmail.com>
Authored: Sun Apr 3 13:59:36 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
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";