diff --git a/pkg/dbal/DbalConsumerHelperTrait.php b/pkg/dbal/DbalConsumerHelperTrait.php index 87e720dac..31fa52b5c 100644 --- a/pkg/dbal/DbalConsumerHelperTrait.php +++ b/pkg/dbal/DbalConsumerHelperTrait.php @@ -6,7 +6,6 @@ use Doctrine\DBAL\Connection; use Doctrine\DBAL\Exception\RetryableException; -use Doctrine\DBAL\ParameterType; use Doctrine\DBAL\Types\Type; use Ramsey\Uuid\Uuid; @@ -40,7 +39,7 @@ protected function fetchMessage(array $queues, int $redeliveryDelay): ?DbalMessa ->addOrderBy('priority', 'asc') ->addOrderBy('published_at', 'asc') ->setParameter('queues', $queues, Connection::PARAM_STR_ARRAY) - ->setParameter('delayedUntil', $now, ParameterType::INTEGER) + ->setParameter('delayedUntil', $now, Type::INTEGER) ->setMaxResults(1); $update = $this->getConnection()->createQueryBuilder()