giant-stone / gmq Goto Github PK

processedat 应该记录 handler 从队列取出的时间戳
dieat 记录 handler 放入 failed 的时间戳
err 记录 handler 的返回的 error 上下文

list messages

./gmqcli.bin -listmsg <queueName> -state failed [-limit 10 -offset 10]

options required: -state
options optional: -limit -offset

get message detail

./gmqcli.bin -getmsg -i <msgId> -q <queueName>

options required: -i -q

NOTE: drop old -get option

usage

delete all related messages from queue

./gmqcli.bin -delqueue <queueName>

debug logging ProcessMsg got unknown subtype -- uri -- queue=foo id=https://foo.bar/id/123/?fmt=json elapsed=0s

可能引起原因：github.com/giant-stone/gmq v0.0.15 版本实现局限。

相同 id 入队两次，并且设置忽略去重参数 gmq.OptIgnoreUnique(true) ，
消费队列时，第一次从 pending 获取 消息 id，从 detail hash 获取消息详情，消费会成功；
第二次由于第一次成功后，清空消息详情（含 payload ），因此第二次处理时，payload 为空 ，payload 中 subtype、uri 也为空。

解决方式二选一：
一、设置去重参数；
二、消费者加个全局中间件，判断 payload 为空则丢弃此消息。

https://github.com/giant-stone/gmq/blob/master/gmq/cmd/gmqcli/main.go#L40
cmdStatsWeekly 合并入 cmdPrintStats

• 支持 macOS and Windows 平台
• 补充文档
• 执行测试时根据变量控制是否跳过 Redis broker 相关测试