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

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

Nats 無(wú)法為沒(méi)有交付組的消費(fèi)者創(chuàng)建隊(duì)列訂閱

Nats 無(wú)法為沒(méi)有交付組的消費(fèi)者創(chuàng)建隊(duì)列訂閱

Go
www說(shuō) 2022-11-08 15:50:20
我正在嘗試在一個(gè)隊(duì)列中創(chuàng)建多個(gè)訂閱者,因此每條消息只能由其中一個(gè)讀取。當(dāng)我第二次嘗試QueueSubscribe時(shí)出現(xiàn)錯(cuò)誤:cannot create a queue subscription for a consumer without a deliver group.我嘗試在一個(gè)應(yīng)用程序中創(chuàng)建兩個(gè)訂閱者并嘗試運(yùn)行兩個(gè)實(shí)例,這是同樣的錯(cuò)誤。以下是訂閱者:s1, err = js.QueueSubscribe(        "KEYS.group",        "queue",        func(m *nats.Msg) {            fmt.Printf("1: %s\n", m.Data)        },    )s2, err = js.QueueSubscribe(        "KEYS.group",        "queue",        func(m *nats.Msg) {            fmt.Printf("2: %s\n", m.Data)        },    )和出版商:_, err := js.AddStream(&nats.StreamConfig{        Name:     "KEYS",        Subjects: []string{"KEYS.group"},        Retention: nats.WorkQueuePolicy,  // tried with default policy if it may be relevant    })for i := 0; i < 20; i++ {        msg := fmt.Sprintf(`{"key": "%d"}`, i)        if _, err := js.Publish("KEYS.group", []byte(msg)); err != nil {            print(err)        }    }我也嘗試添加Durable屬性,但沒(méi)有幫助。
查看完整描述

1 回答

?
寶慕林4294392

TA貢獻(xiàn)2021條經(jīng)驗(yàn) 獲得超8個(gè)贊

由于 nats 服務(wù)器(2.3.6)的版本而出現(xiàn)問(wèn)題,更新到 2.7.2 后一切正常。庫(kù)與舊版本不兼容。



查看完整回答
反對(duì) 回復(fù) 2022-11-08
  • 1 回答
  • 0 關(guān)注
  • 99 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)