Directories
¶
Path | Synopsis |
---|---|
consumer
|
|
acl
command
|
|
broadcast
command
|
|
delay
command
|
|
interceptor
command
|
|
namespace
command
|
|
orderly
command
|
|
pull
command
|
|
retry/concurrent
command
|
|
retry/order
command
* * 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. |
simple
command
|
|
strategy
command
|
|
tag
command
|
|
trace
command
|
|
producer
|
|
acl
command
Package main implements a producer with user custom interceptor.
|
Package main implements a producer with user custom interceptor. |
async
command
|
|
batch
command
|
|
delay
command
|
|
interceptor
command
Package main implements a producer with user custom interceptor.
|
Package main implements a producer with user custom interceptor. |
namespace
command
Package main implements a producer with user custom interceptor.
|
Package main implements a producer with user custom interceptor. |
simple
command
|
|
tag
command
|
|
trace
command
|
|
transaction
command
|
Click to show internal directories.
Click to hide internal directories.