Add comments to turn off SSL into the example code to avoid some compatibility issues (#552)
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 2d96e94..63b0fba 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 @@
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 76c037e..3a57b8f 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 @@
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 d5119ce..008fdc7 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 @@
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 e349b82..d18ddde 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 @@
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";
