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/04 02:31:17 UTC
[rocketmq-clients] branch master updated: Docs: 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 339044b Docs: fix typo
339044b is described below
commit 339044b821bdffe03d1140d9bf598cffeff29a41
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Mon Jul 4 10:31:08 2022 +0800
Docs: fix typo
---
java/example.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/java/example.md b/java/example.md
index 2254903..ad48d70 100644
--- a/java/example.md
+++ b/java/example.md
@@ -31,7 +31,7 @@ Producer producer = provider.newProducerBuilder()
for (int i = 0; i < 1024; i++) {
final SendReceipt sendReceipt = producer.send(message);
}
-// Close it when you don't need the producer any more.
+// Close it when you don't need the producer anymore.
producer.close();
```
@@ -48,7 +48,7 @@ PushConsumer pushConsumer = provider.newPushConsumerBuilder()
return ConsumeResult.SUCCESS;
})
.build();
-// Close it when you don't need the consumer any more.
+// Close it when you don't need the consumer anymore.
pushConsumer.close();
```
@@ -68,6 +68,6 @@ for (MessageView messageView : messageViews) {
// Ack or change invisible time according to your needs.
simpleConsumer.ack(messageView);
}
-// Close it when you don't need the consumer any more.
+// Close it when you don't need the consumer anymore.
simpleConsumer.close();
```