examples/

directory
v1.2.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 15, 2020 License: Apache-2.0

Directories

Path Synopsis
consumer
acl command
broadcast command
delay command
interceptor command
namespace command
orderly command
pull 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL