@@ -69,7 +69,7 @@ public function incrementBounceCount(int $messageId): void
6969 {
7070 $ this ->createQueryBuilder ('m ' )
7171 ->update ()
72- ->set ('m.bounceCount ' , 'm.bounceCount + 1 ' )
72+ ->set ('m.metadata. bounceCount ' , 'm.bounceCount + 1 ' )
7373 ->where ('m.id = :messageId ' )
7474 ->setParameter ('messageId ' , $ messageId )
7575 ->getQuery ()
@@ -79,8 +79,8 @@ public function incrementBounceCount(int $messageId): void
7979 public function getByStatusAndEmbargo (Message \MessageStatus $ status , DateTimeImmutable $ embargo ): array
8080 {
8181 return $ this ->createQueryBuilder ('m ' )
82- ->where ('m.status = :status ' )
83- ->andWhere ('m.embargo IS NULL OR m.embargo <= :embargo ' )
82+ ->where ('m.metadata. status = :status ' )
83+ ->andWhere ('m.schedule. embargo IS NULL OR m.embargo <= :embargo ' )
8484 ->setParameter ('status ' , $ status ->value )
8585 ->setParameter ('embargo ' , $ embargo )
8686 ->getQuery ()
@@ -91,7 +91,7 @@ public function findByIdAndStatus(int $id, Message\MessageStatus $status)
9191 {
9292 return $ this ->createQueryBuilder ('m ' )
9393 ->where ('m.id = :id ' )
94- ->andWhere ('m.status = :status ' )
94+ ->andWhere ('m.metadata. status = :status ' )
9595 ->setParameter ('id ' , $ id )
9696 ->setParameter ('status ' , $ status ->value )
9797 ->getQuery ()
0 commit comments