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 648de15 Block sensitive data in example (#175)
648de15 is described below
commit 648de15626f01778c7bc978f097ca79005f0687f
Author: Aaron Ai <[email protected]>
AuthorDate: Tue Aug 23 15:14:25 2022 +0800
Block sensitive data in example (#175)
---
.../client/java/example/ProducerNormalMessageExample.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
index 266aa01..1b406f5 100644
---
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
+++
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java
@@ -40,17 +40,17 @@ public class ProducerNormalMessageExample {
final ClientServiceProvider provider =
ClientServiceProvider.loadService();
// Credential provider is optional for client configuration.
- String accessKey = "wyME6gI8ZMW4b2s4";
- String secretKey = "E0NEQm7isSKn0R48";
+ String accessKey = "yourAccessKey";
+ String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints =
"rmq-cn-c4d2toqfu25.cn-zhangjiakou.rmq.aliyuncs.com:8080";
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration =
ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
.build();
- String topic = "normalTopic";
+ String topic = "yourNormalTopic";
final Producer producer = provider.newProducerBuilder()
.setClientConfiguration(clientConfiguration)
// Set the topic name(s), which is optional. It makes producer
could prefetch the topic route before