Directories
¶
| Path | Synopsis |
|---|---|
|
consumer
|
|
|
retry/order
* * 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.
|
* * 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. |
|
producer
|
|
|
acl
Package main implements a producer with user custom interceptor.
|
Package main implements a producer with user custom interceptor. |
|
interceptor
Package main implements a producer with user custom interceptor.
|
Package main implements a producer with user custom interceptor. |
|
namespace
Package main implements a producer with user custom interceptor.
|
Package main implements a producer with user custom interceptor. |
Click to show internal directories.
Click to hide internal directories.