Parcourir la source

根据消费的状态进行返回调整

shizhongqi il y a 8 mois
Parent
commit
2da54480e9
1 fichiers modifiés avec 3 ajouts et 1 suppressions
  1. 3 1
      common/components/rabbitmq/ptConsumer.php

+ 3 - 1
common/components/rabbitmq/ptConsumer.php

@@ -49,8 +49,10 @@ class ptConsumer implements ConsumerInterface
                     $result = false;
                     $result = false;
             }
             }
 
 
-            if ($result) {
+            if ($result == ConsumerInterface::MSG_ACK) {
                 return ConsumerInterface::MSG_ACK;
                 return ConsumerInterface::MSG_ACK;
+            } elseif ($result == ConsumerInterface::MSG_REJECT){
+                return ConsumerInterface::MSG_REJECT;
             } else {
             } else {
                 noticeUtil::push("跑腿发单的消费者报错:Notify message processing failed", '15280215347');
                 noticeUtil::push("跑腿发单的消费者报错:Notify message processing failed", '15280215347');
                 return ConsumerInterface::MSG_REQUEUE;
                 return ConsumerInterface::MSG_REQUEUE;