{

$serializer =$this->createSerializer();

$connection =$this->createMock(Connection::class);

$connection->method('getConfiguration')->willReturn([

'redelivery_max_count' =>3,

]);

$driverException =newPDOException(new \PDOException('Deadlock',40001));

$connection->method('get')->willThrowException(newDeadlockException('Deadlock',$driverException));

$receiver =newDoctrineReceiver($connection,$serializer);

$actualEnvelopes =$receiver->get();

$this->assertSame([],$actualEnvelopes);

}

publicfunctiontestOccursRetryableExceptionAfterMaxCountFromConnection()

{

$serializer =$this->createSerializer();

$connection =$this->createMock(Connection::class);

$connection->method('getConfiguration')->willReturn([

'redelivery_max_count' =>2,

]);

$driverException =newPDOException(new \PDOException('Deadlock',40001));

$connection->method('get')->willThrowException(newDeadlockException('Deadlock',$driverException));

$receiver =newDoctrineReceiver($connection,$serializer);

$actualEnvelopes =$receiver->get();

$this->assertSame([],$actualEnvelopes);

$this->assertSame([],$receiver->get());

$this->assertSame([],$receiver->get());

try {

$receiver->get();

}catch (TransportException$exception) {

}

$this->assertSame([],$receiver->get());

$this->assertSame([],$receiver->get());

$this->expectException(TransportException::class);

$receiver->get();

}

'queue_name' =>'default',

'redeliver_timeout' =>3600,

'auto_setup' =>true,

'redelivery_max_count' =>3,

];

$configuration = ['connection' =>$components['host']];

$configuration +=$options +$query +self::DEFAULT_OPTIONS;

$configuration['redelivery_max_count'] =filter_var($configuration['redelivery_max_count'],FILTER_VALIDATE_INT);

$configuration['auto_setup'] =filter_var($configuration['auto_setup'],FILTER_VALIDATE_BOOLEAN);

class DoctrineReceiverimplements ReceiverInterface, MessageCountAwareInterface, ListableReceiverInterface

{

privateconstMAX_RETRIES =3;

private$retryingSafetyCounter =0;

private$connection;

private$serializer;

$doctrineEnvelope =$this->connection->get();

$this->retryingSafetyCounter =0;// reset counter

}catch (RetryableException$exception) {

if (++$this->retryingSafetyCounter >=$this->connection->getConfiguration()['redelivery_max_count']) {

if (++$this->retryingSafetyCounter >=self::MAX_RETRIES) {

$this->retryingSafetyCounter =0;// reset counter

thrownewTransportException($exception->getMessage(),0,$exception);

}