修改延迟队列时间
This commit is contained in:
parent
7f7fd558c1
commit
db14967d6c
@ -278,7 +278,7 @@ class InquiryService extends BaseService
|
|||||||
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
|
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
|
||||||
$message = new CancelUnpayOrdersDelayDirectProducer($data);
|
$message = new CancelUnpayOrdersDelayDirectProducer($data);
|
||||||
// 快速/购药-5分钟
|
// 快速/购药-5分钟
|
||||||
$message->setDelayMs(1000 * 60 * 60 * 24);
|
$message->setDelayMs(1000 * 60 * 5);
|
||||||
$producer = $this->container->get(Producer::class);
|
$producer = $this->container->get(Producer::class);
|
||||||
$res = $producer->produce($message);
|
$res = $producer->produce($message);
|
||||||
if (!$res) {
|
if (!$res) {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user