25 lines
542 B
PHP
25 lines
542 B
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Entity\Repository;
|
|
|
|
use App\Doctrine\Repository;
|
|
use App\Entity;
|
|
|
|
class MessengerMessageRepository extends Repository
|
|
{
|
|
public function clearQueue(?string $queueName = null): void
|
|
{
|
|
$qb = $this->em->createQueryBuilder()
|
|
->delete(Entity\MessengerMessage::class, 'mm');
|
|
|
|
if (!empty($queueName)) {
|
|
$qb->where('mm.queueName = :queueName')
|
|
->setParameter('queueName', $queueName);
|
|
}
|
|
|
|
$qb->getQuery()->execute();
|
|
}
|
|
}
|