RpcCommunicationTest.php

Go to the documentation of this file.

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

use Magento\Framework\MessageQueue\UseCase\QueueTestCaseAbstract;

class RpcCommunicationTest extends QueueTestCaseAbstract
{
    protected $consumers = ['synchronousRpcTestConsumer.deprecated'];

    public function testSynchronousRpcCommunication()
    {
        $input = 'Input value';
        $response = $this->publisher->publish('synchronous.rpc.test.deprecated', $input);
        $this->assertEquals($input . ' processed by RPC handler', $response);
    }
}