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";