[GitHub] [rocketmq-client-go] Me1onRind opened a new issue #382: [NATIVE]No add %RETRY%topic's callback fucntion and send message back to deal message queue in consumeMessageOrderly

[GitBox]

Me1onRind opened a new issue #382: [NATIVE]No add %RETRY%topic's callback 
fucntion and  send message back to deal message queue in consumeMessageOrderly 
URL: https://github.com/apache/rocketmq-client-go/issues/382
 
 
   When I test retry message, I find two question.
   1、Only add topic callback, not add %RETRY%topic  callback in 
*pushConsumer.Subscribe
   ```go
   func (pc *pushConsumer) Subscribe(topic string, selector MessageSelector,
       f func(context.Context, ...*primitive.MessageExt) (ConsumeResult, 
error)) error {
       // codes
       if pc.option.ConsumerModel == Clustering {
           // codes
   
           //  I think need add the following codes
           // pc.consumeFunc.Add(&PushConsumerCallback{
           //     f:     f,   
           //     topic: retryTopic,
           // })   
       }    
   
       pc.consumeFunc.Add(&PushConsumerCallback{
           f:     f,   
           topic: topic,
       })
   ```
   emmm, I will push a PR by the way
   
   2、When  ReconsumeTimes to limit in function consumeMessageOrderly()，send 
back message to MQ，will  send back to %DLQ%topic other than %RETRY%topic.
   ```go
   func (pc *pushConsumer) checkReconsumeTimes(msgs []*primitive.MessageExt) 
bool {
   // other codes
       if !pc.sendMessageBack("", msg, -1) {   //  delayLevel = 1
   // other codes
   }
   ```
   In RocketMq, delayLevel = -1 means directly send to %DLQ% ... So will it 
change ?

----------------------------------------------------------------
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:
us...@infra.apache.org


With regards,
Apache Git Services