Merge pull request #671 from dvdknaap/fixNotSendingAckMessages

check for type
php-amqplib · Nov 11, 2021 · 9829eb0 · 9829eb0
2 parents 63d047d + 457e621
commit 9829eb0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/RabbitMq/BatchConsumer.php b/RabbitMq/BatchConsumer.php
@@ -220,7 +220,7 @@ private function handleProcessFlag($deliveryTag, $processFlag)
         } elseif ($processFlag === ConsumerInterface::MSG_REJECT) {
             // Reject and drop
             $this->getMessageChannel($deliveryTag)->basic_reject($deliveryTag, false);
-        } elseif ($processFlag == ConsumerInterface::MSG_ACK_SENT) {
+        } elseif ($processFlag === ConsumerInterface::MSG_ACK_SENT) {
             // do nothing, ACK should be already sent
         } else {
             // Remove message from queue only if callback return not false