contamobi / CmobiRabbitmqBundle

        $this->assertEquals('caller_test', $rpcClient->getFromName());

    }

    public function testGetResponse()

    {

        $rpcClient = new RpcClient('test', $this->getConnectionManagerMock(), 'caller_test');

        /** @Todo prevent infinite while - improve it */

        $rpcClient->setResponse('testGetResponse() - OK');

        $rpcClient->publish('test');

        $rpcClient->onResponse(

            $this->getCmobiAMQPMessage('testGetResponse() - OK',

                $rpcClient->getCurrentCorrelationId())

        );

        $this->assertEquals('testGetResponse() - OK', $rpcClient->getResponse());

    }

    public function testGenerateCorrelationId()

    {

        $this->assertRegExp(sprintf('/%s/', $rpcClient->getCurrentCorrelationId()), $rpcClient->getQueueName());

    }

    public function testGetCurrentCorrelationId()

    {

        $rpcClient = new RpcClient('test', $this->getConnectionManagerMock(), 'caller_test');

        /** @Todo prevent infinite while - improve it */

        $rpcClient->setResponse('testGetResponse() - OK');

        $rpcClient->publish('test');

        $rpcClient->onResponse(

            $this->getCmobiAMQPMessage('testGetResponse() - OK',

                $rpcClient->getCurrentCorrelationId())

        );

        $this->assertNotNull($rpcClient->getCurrentCorrelationId());

    }

    /**

     * @return ConnectionManager