for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/*
* This file is part of the Sonata Project package.
*
* (c) Thomas Rabaix <[email protected]>
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Sonata\NotificationBundle\Selector;
use Doctrine\Common\Persistence\ManagerRegistry;
use Sonata\NotificationBundle\Model\MessageInterface;
class ErroneousMessagesSelector
{
/**
* @var string
protected $class;
* @var ManagerRegistry
protected $registry;
* @param ManagerRegistry $registry
* @param string $class
public function __construct(ManagerRegistry $registry, $class)
$this->registry = $registry;
$this->class = $class;
}
* Retrieve messages with given type(s) and restrict to max attempts count.
* @param array $types
* @param int $maxAttempts
* @return array
public function getMessages(array $types, $maxAttempts = 5)
$query = $this->registry->getManagerForClass($this->class)->getRepository($this->class)
->createQueryBuilder('m')
->where('m.state = :erroneousState')
->andWhere('m.restartCount < :maxAttempts');
$parameters = array(
'erroneousState' => MessageInterface::STATE_ERROR,
'maxAttempts' => $maxAttempts,
);
if (count($types) > 0) {
$query->andWhere('m.type IN (:types)');
$parameters['types'] = $types;
$query->setParameters($parameters);
return $query->getQuery()->execute();
sonata-project /
SonataNotificationBundle
