|
|
|
@@ -50,7 +50,7 @@ func InstallmentPaymentAutoRepaidConsume(queue md.MqQueue) { |
|
|
|
} |
|
|
|
|
|
|
|
func handleInstallmentPaymentAutoRepaidConsume(msgData []byte) error { |
|
|
|
time.Sleep(time.Duration(2) * time.Millisecond) //休眠2毫秒 |
|
|
|
time.Sleep(time.Duration(1) * time.Millisecond) //休眠1毫秒 |
|
|
|
|
|
|
|
//1、解析mq中queue的数据结构体 |
|
|
|
var msg *md2.InstallmentPaymentStructForAutoRepaid |
|
|
|
|
