diff --git a/pkg/dbal/DbalConsumerHelperTrait.php b/pkg/dbal/DbalConsumerHelperTrait.php index 31fa52b5c..55ec77c00 100644 --- a/pkg/dbal/DbalConsumerHelperTrait.php +++ b/pkg/dbal/DbalConsumerHelperTrait.php @@ -129,9 +129,10 @@ protected function removeExpiredMessages(): void ->delete($this->getContext()->getTableName()) ->andWhere('(time_to_live IS NOT NULL) AND (time_to_live < :now)') ->andWhere('delivery_id IS NULL') - ->andWhere('redelivered = false') + ->andWhere('redelivered = :redelivered') ->setParameter(':now', time(), Type::BIGINT) + ->setParameter('redelivered', false, Type::BOOLEAN) ; try {