Enable OpenSSL for proton and MQTT

ctron · Apr 4, 2019 · 3632e07 · 3632e07
1 parent f6f3d6a
commit 3632e07
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 1 deletion.
diff --git a/containers/base/Dockerfile b/containers/base/Dockerfile
@@ -11,7 +11,8 @@ RUN yum install -y java-11-openjdk java-11-openjdk-devel rh-maven35 iproute git
 RUN yum install -y lsof
 
 ENV \
-    NETTY_TCNATIVE_VERSION=${NETTY_TCNATIVE_VERSION}
+    NETTY_TCNATIVE_VERSION=${NETTY_TCNATIVE_VERSION} \
+    WITH_OPENSSL=true
 
 RUN yum install -y apr
 

diff --git a/simulator-consumer/src/main/java/de/dentrassi/hono/simulator/consumer/Application.java b/simulator-consumer/src/main/java/de/dentrassi/hono/simulator/consumer/Application.java
@@ -162,6 +162,7 @@ private ProtonClientOptions getOptions() {
         final ProtonClientOptions options = new ProtonClientOptions();
 
         is("WITH_OPENSSL", () -> {
+            System.out.println("Using OpenSSL for proton");
             options.setSslEngineOptions(new OpenSSLEngineOptions());
         });
 

diff --git a/simulator-mqtt/src/main/java/de/dentrassi/hono/simulator/mqtt/Device.java b/simulator-mqtt/src/main/java/de/dentrassi/hono/simulator/mqtt/Device.java
@@ -11,6 +11,7 @@
 package de.dentrassi.hono.simulator.mqtt;
 
 import static de.dentrassi.hono.demo.common.Register.shouldRegister;
+import static io.glutamate.lang.Environment.is;
 
 import java.util.Random;
 import java.util.concurrent.atomic.AtomicLong;
@@ -23,6 +24,7 @@
 import io.netty.handler.codec.mqtt.MqttConnectReturnCode;
 import io.netty.handler.codec.mqtt.MqttQoS;
 import io.vertx.core.Vertx;
+import io.vertx.core.net.OpenSSLEngineOptions;
 import io.vertx.mqtt.MqttClient;
 import io.vertx.mqtt.MqttClientOptions;
 import io.vertx.mqtt.MqttConnectionException;
@@ -95,6 +97,11 @@ public Device(final Vertx vertx, final String username, final String deviceId, f
         options.setUsername(username + "@" + tenant);
         options.setPassword(password);
 
+        is("WITH_OPENSSL", () -> {
+            System.out.println("Using OpenSSL for MQTT");
+            options.setSslEngineOptions(new OpenSSLEngineOptions());
+        });
+
         this.client = new MqttClientImpl(vertx, options);
 
         this.client.publishCompletionHandler(this::publishComplete);