RemoteServiceCommunicationTest.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\MessageQueue\UseCase;

use Magento\TestModuleSynchronousAmqp\Api\ServiceInterface;

class RemoteServiceCommunicationTest extends QueueTestCaseAbstract
{
    protected $consumers = ['RemoteServiceTestConsumer'];

    public function testRemoteServiceCommunication()
    {
        $input = 'Input value';
        $generatedRemoteService = $this->objectManager->get(ServiceInterface::class);
        $response = $generatedRemoteService->execute($input);
        $this->assertEquals($input . ' processed by RPC handler', $response);
    }
}