update 云发单消息回调

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

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
 
 }