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
+```