- Fixed a problem in the test code which makes it fail on java7
diff --git a/connectors/mqtt/pom.xml b/connectors/mqtt/pom.xml
index 38cdbba..a6ac968 100644
--- a/connectors/mqtt/pom.xml
+++ b/connectors/mqtt/pom.xml
@@ -112,5 +112,11 @@
<type>test-jar</type>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-lang3</artifactId>
+ <version>3.4</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
</project>
diff --git a/connectors/mqtt/src/test/java/org/apache/edgent/test/connectors/mqtt/MqttStreamsTestManual.java b/connectors/mqtt/src/test/java/org/apache/edgent/test/connectors/mqtt/MqttStreamsTestManual.java
index 3a7938c..018c1c6 100644
--- a/connectors/mqtt/src/test/java/org/apache/edgent/test/connectors/mqtt/MqttStreamsTestManual.java
+++ b/connectors/mqtt/src/test/java/org/apache/edgent/test/connectors/mqtt/MqttStreamsTestManual.java
@@ -39,6 +39,7 @@
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
+import org.apache.commons.lang3.StringUtils;
import org.apache.edgent.connectors.mqtt.MqttConfig;
import org.apache.edgent.connectors.mqtt.MqttStreams;
import org.apache.edgent.function.BiFunction;
@@ -791,7 +792,7 @@
// propTester.add("mqtt.persistence", "some.persistence.classname",
// () -> configRef.get().getPersistence());
propTester.add("mqtt.serverURLs", "tcp://somehost:1234,ssl://somehost:5678",
- () -> String.join(",", configRef.get().getServerURLs()));
+ () -> StringUtils.join(configRef.get().getServerURLs(), ","));
propTester.add("mqtt.subscriberIdleReconnectIntervalSec", "14",
() -> ((Integer)configRef.get().getSubscriberIdleReconnectInterval()).toString());
propTester.add("mqtt.trustStore", "some/path/truststore",
diff --git a/platforms/java7/connectors/mqtt/pom.xml b/platforms/java7/connectors/mqtt/pom.xml
index 71c64ed..438754d 100644
--- a/platforms/java7/connectors/mqtt/pom.xml
+++ b/platforms/java7/connectors/mqtt/pom.xml
@@ -121,5 +121,11 @@
<type>test-jar</type>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-lang3</artifactId>
+ <version>3.4</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
</project>
