update introduction.md (#913)

apache · Sep 21, 2022 · 0323905 · 0323905
1 parent a343f1b
commit 0323905
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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,
     })