[GitHub] [rocketmq-client-go] twz915 opened a new issue #302: [Native] push consumer receives multiple messages, but just return on consumer status

[GitBox <gi...@apache.org>]

twz915 opened a new issue #302: [Native] push consumer receives multiple messages, but just return on consumer status
URL: https://github.com/apache/rocketmq-client-go/issues/302
 
 
   It is strange to me that push consumer receives multiple messages, but just return on consumer status. If one of msgs is unsuccessful, but the others are successful, which consumer status should I return?
   
   ```
   	err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx context.Context,
   		msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) {
   		fmt.Printf("subscribe callback: %v \n", msgs)
   		return consumer.ConsumeSuccess, nil
   	})
   ```
   
   https://github.com/apache/rocketmq-client-go/blob/native/examples/consumer/simple/main.go#L37
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services