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/12/08 06:32:40 UTC
[rocketmq-clients] branch master updated: Fix typo
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 71042f47 Fix typo
71042f47 is described below
commit 71042f4791971ce0cdbca4fdcf499819a4727aec
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Thu Dec 8 14:26:21 2022 +0800
Fix typo
---
.../rocketmq/client/java/example/ProducerDelayMessageExample.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 1d128f32..24402914 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
@@ -60,7 +60,7 @@ public class ProducerDelayMessageExample {
.setTopics(topic)
// May throw {@link ClientException} if the producer is not initialized.
.build();
- // Define your message body.a
+ // Define your message body.
byte[] body = "This is a delay message for Apache RocketMQ".getBytes(StandardCharsets.UTF_8);
String tag = "yourMessageTagA";
Duration messageDelayTime = Duration.ofSeconds(10);