You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2022/09/21 07:07:40 UTC
[rocketmq-client-go] branch master updated: update introduction.md (#913)
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 0323905 update introduction.md (#913)
0323905 is described below
commit 03239051fd7fd8f3731957e5b81e70f0d3142645
Author: Oliver <wq...@163.com>
AuthorDate: Wed Sep 21 15:07:33 2022 +0800
update introduction.md (#913)
---
docs/Introduction.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/Introduction.md b/docs/Introduction.md
index 011603a..d515e9a 100644
--- a/docs/Introduction.md
+++ b/docs/Introduction.md
@@ -89,8 +89,8 @@ c, err := rocketmq.NewPushConsumer(
- Subscribe a topic(only support one topic now), and define your consuming function
```
-err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx *consumer.ConsumeMessageContext,
- msgs []*primitive.MessageExt) (consumer.ConsumeResult, error) {
+err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx context.Context,
+ msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) {
rlog.Info("Subscribe Callback", map[string]interface{}{
"msgs": msgs,
})