Šī lapa labāk darbojas, ja pārlūkam ir iespējots JavaScript.
Sākums
Izpētīt
Palīdzība
Pierakstīties
go_rely_warehouse
/
zyos_go_mq_consume
Vērot
4
Pievienot zvaigznīti
0
Atdalīts
0
Kods
Problēmas
0
Izmaiņu pieprasījumi
0
Laidieni
0
Vikivietne
Aktivitāte
Pārlūkot izejas kodu
更新
order_statistics
huangjiajun
pirms 6 mēnešiem
vecāks
003d627393
revīzija
b74a6e247d
1 mainītis faili
ar
1 papildinājumiem
un
1 dzēšanām
Dalītais skats
Salīdzināšanas iespējas
Rādīt statistiku
Lejupielādēt ielāpa failu
Lejupielādēt izmaiņu failu
+1
-1
consume/zhios_task_total.go
+ 1
- 1
consume/zhios_task_total.go
Parādīt failu
@@ -24,7 +24,7 @@ func ZhiosTaskTotal(queue md.MqQueue) {
//1、将自己绑定到交换机上
ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey)
//2、取出数据进行消费
ch.Qos(1)
ch.Qos(1
000
)
delivery := ch.Consume(queue.Name, false)
var res amqp.Delivery
Rakstīt
Priekšskatītījums
Notiek ielāde…
Atcelt
Saglabāt