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();
 ```
-