From 49d08b37744af3b3fa8e2ed679fbffe43f6c52e7 Mon Sep 17 00:00:00 2001 From: Ferdinand Kuhl Date: Thu, 5 Jan 2023 13:22:24 +0100 Subject: [PATCH] Fixing inline doctypes --- Tests/Functional/BusTest.php | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/Tests/Functional/BusTest.php b/Tests/Functional/BusTest.php index 36e01ce..c991156 100644 --- a/Tests/Functional/BusTest.php +++ b/Tests/Functional/BusTest.php @@ -6,6 +6,7 @@ use DigiComp\FlowSymfonyBridge\Messenger\Tests\Functional\Fixtures\Message\Faili use DigiComp\FlowSymfonyBridge\Messenger\Tests\Functional\Fixtures\Message\TestMessage; use DigiComp\FlowSymfonyBridge\Messenger\Transport\TransportsContainer; use Neos\Flow\Tests\FunctionalTestCase; +use Symfony\Component\EventDispatcher\EventDispatcherInterface; use Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineTransport; use Symfony\Component\Messenger\EventListener\StopWorkerOnMessageLimitListener; use Symfony\Component\Messenger\MessageBusInterface; @@ -24,11 +25,11 @@ class BusTest extends FunctionalTestCase $messageBus->dispatch(new TestMessage('Hallo Welt!')); $sendersContainer = $this->objectManager->get(TransportsContainer::class); - /* @var InMemoryTransport $transport1 */ + /** @var InMemoryTransport $transport1 */ $transport1 = $sendersContainer->get('test-in-memory-1'); - /* @var InMemoryTransport $transport2 */ + /** @var InMemoryTransport $transport2 */ $transport2 = $sendersContainer->get('test-in-memory-2'); - /* @var DoctrineTransport $transport3 */ + /** @var DoctrineTransport $transport3 */ $transport3 = $sendersContainer->get('test-doctrine'); $this->assertInstanceOf(InMemoryTransport::class, $transport1); $this->assertInstanceOf(InMemoryTransport::class, $transport2); @@ -62,13 +63,14 @@ class BusTest extends FunctionalTestCase $messageBus->dispatch(new FailingMessage()); $sendersContainer = $this->objectManager->get(TransportsContainer::class); - /* @var DoctrineTransport $transport1 */ + /** @var DoctrineTransport $transport1 */ $transport1 = $sendersContainer->get('test-retry-doctrine'); - /* @var DoctrineTransport $failedTransport */ + /** @var DoctrineTransport $failedTransport */ $failedTransport = $sendersContainer->get('test-failed-doctrine'); $this->assertCount(1, $transport1->all()); $this->assertCount(0, $failedTransport->all()); + /** @var EventDispatcherInterface $eventDispatcher */ $eventDispatcher = $this->objectManager->get('DigiComp.FlowSymfonyBridge.Messenger:EventDispatcher'); $eventDispatcher->addSubscriber(new StopWorkerOnMessageLimitListener(1)); $worker = new Worker(