From 475f22be5ed2f53da72a1aa105f8ced8ff539dfe Mon Sep 17 00:00:00 2001
From: DengBiao <2319963317@qq.com>
Date: Thu, 4 Jan 2024 17:44:34 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E4=BA=91=E5=8F=91=E5=8D=95=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E5=9B=9E=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 consume/cloud_issuance_msg_callback.go | 2 +-
 consume/init.go                        | 9 ++++++---
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/consume/cloud_issuance_msg_callback.go b/consume/cloud_issuance_msg_callback.go
index 47a9d12..d9521c6 100644
--- a/consume/cloud_issuance_msg_callback.go
+++ b/consume/cloud_issuance_msg_callback.go
@@ -25,7 +25,7 @@ func CloudIssuanceMsgCallBackConsume(queue md.MqQueue) {
 	}
 	defer ch.Release()
 	//2、取出数据进行消费
-	ch.Qos(1)
+	ch.Qos(10)
 	delivery := ch.Consume(queue.Name, false)
 
 	var res amqp.Delivery
diff --git a/consume/init.go b/consume/init.go
index 378a0ac..9a32a70 100644
--- a/consume/init.go
+++ b/consume/init.go
@@ -67,9 +67,12 @@ func initConsumes() {
 	//jobs[consumeMd.ZhiosWithdrawReward] = ZhiosWithdrawReward
 	//
 	////jobs[consumeMd.ZhiosRechargeOrderFailDevFunName] = ZhiosRechargeOrderFailDev
-	//
-	//jobs[consumeMd.CloudIssuanceMsgCallBackFunName] = CloudIssuanceMsgCallBackConsume
-	jobs[consumeMd.SupplyCloudChainFenxiaoNewChangeFunName] = SupplyCloudChainFenxiaoNewChangeConsume
+
+	////////////////////////////////////// V1 /////////////////////////////////////////////////////
+	jobs[consumeMd.CloudIssuanceMsgCallBackFunName] = CloudIssuanceMsgCallBackConsume
+
+	//////////////////////////////////////// V2 /////////////////////////////////////////////////////
+	//jobs[consumeMd.SupplyCloudChainFenxiaoNewChangeFunName] = SupplyCloudChainFenxiaoNewChangeConsume
 
 }