4.4.0

* added `DoctrineClearEntityManagerMiddleware`

namespace Symfony\Bridge\Doctrine\Messenger;

use Doctrine\Common\Persistence\ManagerRegistry;

use Symfony\Component\Messenger\Envelope;

use Symfony\Component\Messenger\Exception\UnrecoverableMessageHandlingException;

use Symfony\Component\Messenger\Middleware\MiddlewareInterface;

use Symfony\Component\Messenger\Middleware\StackInterface;

class DoctrineClearEntityManagerMiddleware implements MiddlewareInterface

{

private $managerRegistry;

private $entityManagerName;

public function __construct(ManagerRegistry $managerRegistry, string $entityManagerName = null)

{

$this->managerRegistry = $managerRegistry;

$this->entityManagerName = $entityManagerName;

}

/**

public function handle(Envelope $envelope, StackInterface $stack): Envelope

{

try {

$entityManager = $this->managerRegistry->getManager($this->entityManagerName);

} catch (\InvalidArgumentException $e) {

throw new UnrecoverableMessageHandlingException($e->getMessage(), 0, $e);

}

try {

return $stack->next()->handle($envelope, $stack);

} finally {

$entityManager->clear();

}

}

}

namespace Symfony\Bridge\Doctrine\Tests\Messenger;

use Doctrine\Common\Persistence\ManagerRegistry;

use Doctrine\ORM\EntityManagerInterface;

use Symfony\Bridge\Doctrine\Messenger\DoctrineClearEntityManagerMiddleware;

use Symfony\Component\Messenger\Envelope;

use Symfony\Component\Messenger\Exception\UnrecoverableMessageHandlingException;

use Symfony\Component\Messenger\Test\Middleware\MiddlewareTestCase;

class DoctrineClearEntityManagerMiddlewareTest extends MiddlewareTestCase

{

private $entityManager;

private $managerRegistry;

private $middleware;

private $entityManagerName = 'default';

protected function setUp()

{

$this->entityManager = $this->createMock(EntityManagerInterface::class);

$this->managerRegistry = $this->createMock(ManagerRegistry::class);

$this->managerRegistry

->method('getManager')

->with($this->entityManagerName)

->willReturn($this->entityManager);

$this->middleware = new DoctrineClearEntityManagerMiddleware(

$this->managerRegistry,

$this->entityManagerName

);

}

public function testMiddlewareClearEntityManager()

{

$this->entityManager->expects($this->once())

->method('clear');

$this->middleware->handle(new Envelope(new \stdClass()), $this->getStackMock());

}

public function testInvalidEntityManagerThrowsException()

{

$managerRegistry = $this->createMock(ManagerRegistry::class);

$managerRegistry

->method('getManager')

->with('unknown_manager')

->will($this->throwException(new \InvalidArgumentException()));

$middleware = new DoctrineClearEntityManagerMiddleware($managerRegistry, 'unknown_manager');

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

$middleware->handle(new Envelope(new \stdClass()), $this->getStackMock(false));

}

}