ConsumeMessagesController example

use Symfony\Component\Messenger\MessageBusInterface;

/** * @internal * * @covers \Shopware\Core\Framework\MessageQueue\Api\ConsumeMessagesController */
class ConsumeMessagesControllerTest extends TestCase
{
    public function testInvalidReceiver(): void
    {
        $controller = new ConsumeMessagesController(
            new ServiceLocator([]),
            $this->createMock(MessageBusInterface::class),
            $this->createMock(StopWorkerOnRestartSignalListener::class),
            $this->createMock(EarlyReturnMessagesListener::class),
            $this->createMock(MessageQueueStatsSubscriber::class),
            'async',
            '128M',
            20,
            $this->createMock(LockFactory::class)
        );