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/06/28 07:56:07 UTC
[rocketmq-clients] branch master updated: Java: fix typo in README.md (#22)
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 d9d7d2e Java: fix typo in README.md (#22)
d9d7d2e is described below
commit d9d7d2e1f32690e537ea903c42af029c52d9efc1
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Tue Jun 28 15:56:02 2022 +0800
Java: fix typo in README.md (#22)
---
java/README.md | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/java/README.md b/java/README.md
index e02f800..206232d 100644
--- a/java/README.md
+++ b/java/README.md
@@ -97,7 +97,7 @@ SimpleConsumer simpleConsumer = provider.newSimpleConsumerBuilder()
.setSubscriptionExpressions(Collections.singletonMap(topic, filterExpression))
.build();
// Try to receive message from server.
-final List<MessageView> messageViews = consumer.receive(1, invisibleDuration);
+final List<MessageView> messageViews = simpleConsumer.receive(1, invisibleDuration);
for (MessageView messageView : messageViews) {
// Ack or change invisible time according to your needs.
simpleConsumer.ack(messageView);
@@ -105,4 +105,3 @@ for (MessageView messageView : messageViews) {
// Close it when you don't need the consumer any more.
simpleConsumer.close();
```
-