diff --git a/RabbitMq/BatchConsumer.php b/RabbitMq/BatchConsumer.php index 01ce3ea2..e305486b 100644 --- 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