* * use concurrent consumer model, when Subscribe function return consumer.ConsumeRetryLater, the message will be * send to rocketmq retry topic.

* * use orderly consumer model, when Subscribe function return consumer.SuspendCurrentQueueAMoment, it will be re-send to * local msg queue for later consume if msg.ReconsumeTimes < MaxReconsumeTimes, otherwise, it will be send to rocketmq * DLQ topic, we should manually resolve the msg.