octante / NatsBundle

     * with: natsMessage

     * should: sendMessageToLogger

     */

    public function test_callLogCommand_natsMessage_sendMessageToLogger()

    {

        $loggerMock = $this->getMockBuilder('Monolog\Logger')

            ->disableOriginalConstructor()

            ->setMethods(array('info'))

            ->getMock();

        $loggerMock->expects($this->once())

            ->method('info')

            ->with('Executing "PUBLISH: test"');

        $msg = 'PUBLISH: test';

        $duration = 0.5;

        $connection = $this->getMockBuilder('Octante\NatsBundle\Connection\ConnectionWrapper')

            ->disableOriginalConstructor();

        $sut = new NatsLogger($loggerMock);

        $sut->logCommand($msg, $duration, $connection);

    }

    /**

     * when: callLogCommand

     * with: natsMessage

     * should: sendErrorToLogger

     */

    public function test_callLogCommand_natsMessage_sendErrorToLogger()

    {

        $loggerMock = $this->getMockBuilder('Monolog\Logger')

            ->disableOriginalConstructor()

            ->setMethods(array('error'))

            ->getMock();

        $loggerMock->expects($this->once())

            ->method('error')

            ->with('Executing "PUBLISH: test" failed (1)');

        $msg = 'PUBLISH: test';

        $duration = 0.5;

        $connection = $this->getMockBuilder('Octante\NatsBundle\Connection\ConnectionWrapper')

            ->disableOriginalConstructor();

        $sut = new NatsLogger($loggerMock);

        $sut->logCommand($msg, $duration, $connection, true);

    }

    /**

     * when: callGetNbCommand