This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 53861440 Add comments to turn off SSL into the example code to avoid 
some compatibility issues (#552)
53861440 is described below

commit 53861440de430053c9a5a675a06f22ea1bd54790
Author: Aaron Ai <[email protected]>
AuthorDate: Mon Jun 26 11:55:12 2023 +0800

    Add comments to turn off SSL into the example code to avoid some 
compatibility issues (#552)
---
 .../rocketmq/client/java/example/AsyncSimpleConsumerExample.java       | 3 +++
 .../org/apache/rocketmq/client/java/example/ProducerSingleton.java     | 3 +++
 .../org/apache/rocketmq/client/java/example/PushConsumerExample.java   | 3 +++
 .../org/apache/rocketmq/client/java/example/SimpleConsumerExample.java | 3 +++
 4 files changed, 12 insertions(+)

diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java
index 2d96e946..63b0fba7 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java
@@ -57,6 +57,9 @@ public class AsyncSimpleConsumerExample {
         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
index 76c037ec..3a57b8f6 100644
--- 
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 @@ public class ProducerSingleton {
             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
index d5119ceb..008fdc7e 100644
--- 
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 class PushConsumerExample {
         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
index e349b82a..d18ddde0 100644
--- 
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 class SimpleConsumerExample {
         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";

Reply via email to