go - Go-micro rabbit mq 插件 - 优先发布消息
问题描述
由于支持 RabbitMQ 版本 3.5.0 优先级队列 - https://www.rabbitmq.com/priority.html
如果在队列创建期间传递了 x-max-priority 参数,则可以声明队列。
我可以成功声明一个优先支持的队列
brkrSub := broker.NewSubscribeOptions(
broker.DisableAutoAck(),
rabbitmq.QueueArguments(map[string]interface{}{"x-max-priority": 10}),
)
service.Server().Subscribe(
service.Server().NewSubscriber(
"mytopic",
h.Handle,
server.SubscriberQueue("mytopic.hello"),
server.SubscriberContext(brkrSub.Context),
),
)
但是如何发布指定优先级的消息?
body := &message.MyTestMessage{
Message: fmt.Sprintf("Message number %d", counter),
}
msg := client.NewMessage(
topic,
body,
// TODO: Priority
)
if err := client.Publish(ctx, msg); err != nil {
fmt.Printf("Cannot publish message: ", err.Error())
return
}
我找不到将优先级作为 MessageOption 或 PublishOption 传递的直接方法,但是,似乎有一种方法可以在 client.Publish 上下文中指定其他选项。我是否正在寻找正确的方向,如果是这样,你能帮我一点吗?
编辑:我能够执行以下操作而不会导致任何编译时错误。尽管如此,优先级仍然被忽略,并且消息以通常的方式出现
func setPriority(ctx context.Context, priority int) client.PublishOption {
return func(o *client.PublishOptions) {
o.Context = context.WithValue(ctx, "priority", priority)
}
}
func publish(ctx context.Context, priority int, counter int) {
//body := fmt.Sprintf("hello, I am a message %d", counter)
body := &message.MyTestMessage{
Message: fmt.Sprintf("Message number %d", counter),
}
msg := client.NewMessage(
topic,
body,
)
if err := client.Publish(ctx, msg, setPriority(ctx, priority)); err != nil {
fmt.Printf("Cannot publish message: ", err.Error())
return
}
fmt.Printf("Published message %d to %s \n", counter, topic)
}
解决方案
var brokerOpts broker.PublishOptions
rabbitmq.Priority(uint8(10))(&brokerOpts)
event.Publish(ctx, payload, client.PublishContext(brokerOpts.Context))
推荐阅读
- google-cloud-platform - terraform 将云作曲家从 1.0 升级到 2.0?
- javascript - 在 JavaScript 中使用集中验证函数
- powerapps - 如何在 Microsoft Power App 画布应用程序中将记录插入到多个表中?
- python - PyQt 的“pyqtProperty” VS python 的标准“属性”
- sql - 日期过滤优化
- javascript - 如何使用 Express.js 将用户重定向到不同的网页?(是的,我尝试过使用 `redirect` 方法)
- c# - WebProxy - 使用 C# 代码或机器来配置
- elasticsearch - 如何更动态地计算具有字符串数组值的文档
- reactjs - 使用 Next.js 导入动态英雄图标
- google-apps-script - Google 表格插件 - 未找到已发布版本的 POST 端点