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 <[email protected]>
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)
