第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

Go-micro rabbit mq 插件 - 優(yōu)先發(fā)布消息

Go-micro rabbit mq 插件 - 優(yōu)先發(fā)布消息

Go
溫溫醬 2022-05-23 14:55:10
由于支持 RabbitMQ 版本 3.5.0 優(yōu)先級隊列 - https://www.rabbitmq.com/priority.html如果在隊列創(chuàng)建期間傳遞了 x-max-priority 參數(shù),則可以聲明隊列。我可以成功聲明一個優(yōu)先支持的隊列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),        ),    )但是如何發(fā)布指定優(yōu)先級的消息?    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    }我找不到將優(yōu)先級作為 MessageOption 或 PublishOption 傳遞的直接方法,但是,似乎有一種方法可以在 client.Publish 上下文中指定其他選項。我是否正在尋找正確的方向,如果是這樣,你能幫我一點嗎?編輯:我能夠執(zhí)行以下操作而不會導致任何編譯時錯誤。盡管如此,優(yōu)先級仍然被忽略,并且消息以通常的方式出現(xiàn)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)}
查看完整描述

2 回答

?
蕪湖不蕪

TA貢獻1796條經(jīng)驗 獲得超7個贊

嘗試這樣的事情:


func publishMessageToChan(queue *amqp.Queue, channel *amqp.Channel, messageToQueue string) error {

    return channel.Publish(

        "<exchange>", // exchange

        "<queue>",    // routing key

        false,        // mandatory

        false,        // immediate

        amqp.Publishing{

            Timestamp:   time.Now(),

            ContentType: "text/plain",

            Body:        []byte(messageToQueue),

            Priority:    0, // <-- Priority here < 0 to 9>

        })

}

使用庫“github.com/streadway/amqp”


查看完整回答
反對 回復 2022-05-23
?
慕田峪7331174

TA貢獻1828條經(jīng)驗 獲得超13個贊

var brokerOpts broker.PublishOptions

rabbitmq.Priority(uint8(10))(&brokerOpts)


event.Publish(ctx, payload, client.PublishContext(brokerOpts.Context))


查看完整回答
反對 回復 2022-05-23
  • 2 回答
  • 0 關注
  • 165 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網(wǎng)微信公眾號