florianajir / rabbitmq-sql-worker

    /**

     *

     */

    public function testExecuteWithInvalidArgumentThrew()

    {

        $transformer = $this->getTransformerMock(1, $this->throwException(new InvalidArgumentException()));

        $persister = $this->getPersisterMock();

        $serializer = $this->getSerializer();

        $logger = $this->getLoggerMock();

        $logger

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

            ->method('info')

        ;

        $logger

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

            ->method('warning')

        ;

        $consumer = new SqlConsumer($transformer, $persister, $serializer);

        $consumer->setLogger($logger);

        $data = new GnaaMessage();

        $data

            ->setType(uniqid())

            ->setData($serializer->serialize(array(), 'json'));

        $msg = new AMQPMessage($serializer->serialize($data, 'json'));

        $result = $consumer->execute($msg);

        $this->assertFalse($result);

    }

    /**

     *

    /**

     *

     */

    public function testExecuteWithExceptionThrew()

    {

        $transformer = $this->getTransformerMock(1, $this->throwException(new Exception()));

        $persister = $this->getPersisterMock();

        $serializer = $this->getSerializer();

        $logger = $this->getLoggerMock();

        $logger

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

            ->method('info')

        ;

        $logger

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

            ->method('error')

        ;

        $consumer = new SqlConsumer($transformer, $persister, $serializer);

        $consumer->setLogger($logger);

        $data = new GnaaMessage();

        $data

            ->setType(uniqid())

            ->setData($serializer->serialize(array(), 'json'));

        $msg = new AMQPMessage();

        $msg->body = $serializer->serialize($data, 'json');

        $this->setExpectedException('Exception');

        $consumer->execute($msg);

    }

    /**

     *