You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/29 03:02:19 UTC
[rocketmq-clients] branch master updated: Polish the java example (#88)
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 80ed867 Polish the java example (#88)
80ed867 is described below
commit 80ed8674ac5beb9f9a13c5bbb94a046dc162a6b5
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Fri Jul 29 11:02:15 2022 +0800
Polish the java example (#88)
1. replace the endpoints port with 8080
2. indicate that the credential provider is optional
---
.../apache/rocketmq/client/java/example/AsyncProducerExample.java | 5 ++++-
.../rocketmq/client/java/example/AsyncSimpleConsumerExample.java | 5 ++++-
.../rocketmq/client/java/example/ProducerDelayMessageExample.java | 5 ++++-
.../rocketmq/client/java/example/ProducerFifoMessageExample.java | 5 ++++-
.../rocketmq/client/java/example/ProducerNormalMessageExample.java | 7 +++++--
.../client/java/example/ProducerTransactionMessageExample.java | 5 ++++-
.../apache/rocketmq/client/java/example/PushConsumerExample.java | 5 ++++-
.../apache/rocketmq/client/java/example/SimpleConsumerExample.java | 5 ++++-
8 files changed, 33 insertions(+), 9 deletions(-)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java
index de0f390..8ef7eaf 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java
@@ -39,11 +39,14 @@ public class AsyncProducerExample {
public static void main(String[] args) throws ClientException, IOException {
final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints = "foobar.com:8081";
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
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 2bda9b5..8d0875d 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
@@ -45,11 +45,14 @@ public class AsyncSimpleConsumerExample {
public static void main(String[] args) throws ClientException, IOException {
final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints = "foobar.com:8081";
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java
index 1fae792..9d778b6 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java
@@ -39,11 +39,14 @@ public class ProducerDelayMessageExample {
public static void main(String[] args) throws ClientException, IOException {
final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints = "foobar.com:8081";
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java
index e087e46..823aab4 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java
@@ -38,11 +38,14 @@ public class ProducerFifoMessageExample {
public static void main(String[] args) throws ClientException, IOException {
final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints = "foobar.com:8081";
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
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 c28800e..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
@@ -37,12 +37,15 @@ public class ProducerNormalMessageExample {
}
public static void main(String[] args) throws ClientException, IOException {
+ final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
- String endpoints = "foobar.com:8081";
- final ClientServiceProvider provider = ClientServiceProvider.loadService();
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java
index ba71357..f3b7a95 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java
@@ -41,11 +41,14 @@ public class ProducerTransactionMessageExample {
public static void main(String[] args) throws ClientException, IOException {
final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints = "foobar.com:8081";
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
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 79bfd3c..377c4ee 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
@@ -39,11 +39,14 @@ public class PushConsumerExample {
public static void main(String[] args) throws ClientException, IOException, InterruptedException {
final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints = "foobar.com:8081";
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)
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 afbef23..5428145 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
@@ -41,11 +41,14 @@ public class SimpleConsumerExample {
public static void main(String[] args) throws ClientException, IOException {
final ClientServiceProvider provider = ClientServiceProvider.loadService();
+
+ // Credential provider is optional for client configuration.
String accessKey = "yourAccessKey";
String secretKey = "yourSecretKey";
SessionCredentialsProvider sessionCredentialsProvider =
new StaticSessionCredentialsProvider(accessKey, secretKey);
- String endpoints = "foobar.com:8081";
+
+ String endpoints = "foobar.com:8080";
ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
.setEndpoints(endpoints)
.setCredentialProvider(sessionCredentialsProvider)