Documentation ¶
Overview ¶
*
- 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.
Click to show internal directories.
Click to hide internal directories.