diff --git a/Entity/Repository/JobRepository.php b/Entity/Repository/JobRepository.php index f9edc9ec..52234980 100644 --- a/Entity/Repository/JobRepository.php +++ b/Entity/Repository/JobRepository.php @@ -100,7 +100,7 @@ public function getOrCreateIfNotExists($command, array $args = array()) $firstJob = $this->_em->createQuery("SELECT j FROM JMSJobQueueBundle:Job j WHERE j.command = :command AND j.args = :args ORDER BY j.id ASC") ->setParameter('command', $command) - ->setParameter('args', $args, 'json_array') + ->setParameter('args', $args, Type::JSON_ARRAY) ->setMaxResults(1) ->getSingleResult();