You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2024/10/08 09:15:32 UTC
(rocketmq-client-go) branch master updated: fix typo: PullConsumer -> PushConsumer in Introduction.md (#1166)
This is an automated email from the ASF dual-hosted git repository.
yuzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 3e6b910 fix typo: PullConsumer -> PushConsumer in Introduction.md (#1166)
3e6b910 is described below
commit 3e6b9108bd0d621f61c9bc679c6a8398d089d6c2
Author: Yixia <87...@users.noreply.github.com>
AuthorDate: Tue Oct 8 17:15:26 2024 +0800
fix typo: PullConsumer -> PushConsumer in Introduction.md (#1166)
Fix the error description under PushConsumer interface
---
docs/Introduction.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/Introduction.md b/docs/Introduction.md
index d515e9a..6fedec8 100644
--- a/docs/Introduction.md
+++ b/docs/Introduction.md
@@ -66,10 +66,10 @@ now only support `PushConsumer`
#### Interface
```
PushConsumer interface {
- // Start the PullConsumer for consuming message
+ // Start the PushConsumer for consuming message
Start() error
- // Shutdown the PullConsumer, all offset of MessageQueue will be sync to broker before process exit
+ // Shutdown the PushConsumer, all offset of MessageQueue will be sync to broker before process exit
Shutdown() error
// Subscribe a topic for consuming
Subscribe(topic string, selector consumer.MessageSelector,
@@ -127,4 +127,4 @@ err = testAdmin.DeleteTopic(
//admin.WithBrokerAddrDelete("127.0.0.1:10911"), //optional
//admin.WithNameSrvAddr(nameSrvAddr), //optional
)
-```
\ No newline at end of file
+```