|
@@ -43,6 +43,10 @@ func ZhiosFastReturnOrderPay(queue md.MqQueue) { |
|
|
fmt.Println(err) |
|
|
fmt.Println(err) |
|
|
if err == nil { |
|
|
if err == nil { |
|
|
_ = res.Ack(true) |
|
|
_ = res.Ack(true) |
|
|
|
|
|
} else { |
|
|
|
|
|
var msg *md.ZhiosFatReturnOrderPay |
|
|
|
|
|
json.Unmarshal(res.Body, &msg) |
|
|
|
|
|
ch.Publish(queue.ExchangeName, msg, queue.RoutKey) |
|
|
} |
|
|
} |
|
|
} else { |
|
|
} else { |
|
|
panic(errors.New("error getting message")) |
|
|
panic(errors.New("error getting message")) |
|
|