Repository: incubator-edgent Updated Branches: refs/heads/master 282d14167 -> f8a15989c
Tolerate trailing spaces in serverURLs MqttConfig properties file Had a space at the end of the property and it was unclear why the URL failed validation. Project: http://git-wip-us.apache.org/repos/asf/incubator-edgent/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-edgent/commit/9c08a34e Tree: http://git-wip-us.apache.org/repos/asf/incubator-edgent/tree/9c08a34e Diff: http://git-wip-us.apache.org/repos/asf/incubator-edgent/diff/9c08a34e Branch: refs/heads/master Commit: 9c08a34e223f9d0c951b6f7ccc1e977c899a14f9 Parents: a6090c8 Author: Dale LaBossiere <dlab...@us.ibm.com> Authored: Mon Jan 16 15:54:53 2017 -0500 Committer: Dale LaBossiere <dlab...@us.ibm.com> Committed: Mon Jan 16 15:54:53 2017 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/edgent/connectors/mqtt/MqttConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-edgent/blob/9c08a34e/connectors/mqtt/src/main/java/org/apache/edgent/connectors/mqtt/MqttConfig.java ---------------------------------------------------------------------- diff --git a/connectors/mqtt/src/main/java/org/apache/edgent/connectors/mqtt/MqttConfig.java b/connectors/mqtt/src/main/java/org/apache/edgent/connectors/mqtt/MqttConfig.java index 4ede290..4880b57 100644 --- a/connectors/mqtt/src/main/java/org/apache/edgent/connectors/mqtt/MqttConfig.java +++ b/connectors/mqtt/src/main/java/org/apache/edgent/connectors/mqtt/MqttConfig.java @@ -124,7 +124,7 @@ public class MqttConfig { setConfig(p, "mqtt.persistence", val -> config.setPersistence(newPersistenceProvider(val))); setConfig(p, "mqtt.serverURLs", - val -> config.setServerURLs(val.split(","))); + val -> config.setServerURLs(val.trim().split(","))); setConfig(p, "mqtt.subscriberIdleReconnectIntervalSec", val -> config.setSubscriberIdleReconnectInterval(Integer.valueOf(val))); setConfig(p, "mqtt.trustStore",
