Il sito funziona meglio con JavaScript.
Home
Esplora
Aiuto
Accedi
go_rely_warehouse
/
zyos_go_mq_consume
Segui
4
Vota
0
Forka
0
Codice
Problemi
0
Pull Requests
0
Rilasci
0
Wiki
Attività
Sfoglia il codice sorgente
抖音团长商品
three
huangjiajun
1 anno fa
parent
4c5bbc17d3
commit
c8c8cc11c7
1 ha cambiato i file
con
1 aggiunte
e
1 eliminazioni
Visualizzazione separata
Opzioni Diff
Mostra statistiche
Scarica il file Patch
Scarica il file Diff
+1
-1
consume/zhios_tikTok_goods_update.go
+ 1
- 1
consume/zhios_tikTok_goods_update.go
Vedi File
@@ -25,7 +25,7 @@ func ZhiosTikTokUpdate(queue md.MqQueue) {
//1、将自己绑定到交换机上
ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey)
//2、取出数据进行消费
ch.Qos(5)
ch.Qos(5
0
)
delivery := ch.Consume(queue.Name, true)
var res amqp.Delivery
Scrivi
Anteprima
Caricamento…
Annulla
Salva