|
|
@@ -67,11 +67,13 @@ class stockConsumer implements ConsumerInterface
|
|
|
Yii::getLogger()->flush(true);
|
|
|
}
|
|
|
noticeUtil::push("库存的消费者报错:Stock message processing failed");
|
|
|
- return ConsumerInterface::MSG_REQUEUE;
|
|
|
+ //return ConsumerInterface::MSG_REQUEUE;
|
|
|
+ return ConsumerInterface::MSG_ACK;
|
|
|
}
|
|
|
} catch (\Exception $e) {
|
|
|
noticeUtil::push("库存的消费者报错:" . $e->getMessage());
|
|
|
- return ConsumerInterface::MSG_REQUEUE;
|
|
|
+ //return ConsumerInterface::MSG_REQUEUE;
|
|
|
+ return ConsumerInterface::MSG_ACK;
|
|
|
}
|
|
|
}
|
|
|
|