Add comments to turn off SSL into the example code to avoid some comp…

…atibility issues (#552)
apache · Jun 26, 2023 · 5386144 · 5386144
1 parent f1d5e95
commit 5386144
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 0 deletions.
diff --git a/...ent/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java b/...ent/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java
@@ -57,6 +57,9 @@ public static void main(String[] args) throws ClientException {
         String endpoints = "foobar.com:8080";
         ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
             .setEndpoints(endpoints)
+            // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in
+            // client configuration to solve the problem please if SSL is not essential.
+            // .enableSsl(false)
             .setCredentialProvider(sessionCredentialsProvider)
             .build();
         String consumerGroup = "yourConsumerGroup";

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java
@@ -51,6 +51,9 @@ private static Producer buildProducer(TransactionChecker checker, String... topi
             new StaticSessionCredentialsProvider(ACCESS_KEY, SECRET_KEY);
         ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
             .setEndpoints(ENDPOINTS)
+            // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in
+            // client configuration to solve the problem please if SSL is not essential.
+            // .enableSsl(false)
             .setCredentialProvider(sessionCredentialsProvider)
             .build();
         final ProducerBuilder builder = provider.newProducerBuilder()

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/PushConsumerExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/PushConsumerExample.java
@@ -49,6 +49,9 @@ public static void main(String[] args) throws ClientException, InterruptedExcept
         String endpoints = "foobar.com:8080";
         ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
             .setEndpoints(endpoints)
+            // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in
+            // client configuration to solve the problem please if SSL is not essential.
+            // .enableSsl(false)
             .setCredentialProvider(sessionCredentialsProvider)
             .build();
         String tag = "yourMessageTagA";

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java
@@ -52,6 +52,9 @@ public static void main(String[] args) throws ClientException {
         String endpoints = "foobar.com:8080";
         ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
             .setEndpoints(endpoints)
+            // On some Windows platforms, you may encounter SSL compatibility issues. Try turning off the SSL option in
+            // client configuration to solve the problem please if SSL is not essential.
+            // .enableSsl(false)
             .setCredentialProvider(sessionCredentialsProvider)
             .build();
         String consumerGroup = "yourConsumerGroup";