-
Notifications
You must be signed in to change notification settings - Fork 438
Closed
Labels
docDocument, comments and clean codeDocument, comments and clean code
Description
BUG REPORT
-
Please describe the issue you observed:
- What did you do (The steps to reproduce)?
err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx *consumer.ConsumeMessageContext,
msgs []*primitive.MessageExt) (consumer.ConsumeResult, error) {
rlog.Info("Subscribe Callback", map[string]interface{}{
"msgs": msgs,
})
return consumer.ConsumeSuccess, nil
})
ctx *consumer.ConsumeMessageContext should be ctx context.Context
- What did you expect to see?
- What did you see instead?
-
Please tell us about your environment:
-
What is your OS?
-
What is your client version?
-
What is your RocketMQ version?
-
-
Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
Metadata
Metadata
Assignees
Labels
docDocument, comments and clean codeDocument, comments and clean code