contamobi / CmobiRabbitmqBundle

use Cmobi\RabbitmqBundle\Tests\BaseTestCase;

use Cmobi\RabbitmqBundle\Transport\PubSub\SubscriberQueueCallback;

class SubscriberQueueCallbackTest extends BaseTestCase

{

    public function testGetQueueService()

    {

        $rpcQueueCallback = new SubscriberQueueCallback($this->getQueueServiceMock());

        $queueService = $rpcQueueCallback->getQueueService();

        $this->assertInstanceOf(QueueServiceInterface::class, $queueService);

    }

    /**

     * @return QueueServiceInterface

     */

    protected function getQueueServiceMock()

    {

        $queueServiceMock = $this->getMockBuilder(QueueServiceInterface::class)

            ->disableOriginalConstructor()

            ->getMock();

        $queueServiceMock->method('handle')

            ->willReturn('');

        return $queueServiceMock;

    }

}

use Cmobi\RabbitmqBundle\Transport\Rpc\RpcQueueCallback;

use Cmobi\RabbitmqBundle\Tests\BaseTestCase;

class RpcQueueCallbackTest extends BaseTestCase

{

    public function testGetQueueService()

    {

        $rpcQueueCallback = new RpcQueueCallback($this->getQueueServiceMock());

        $queueService = $rpcQueueCallback->getQueueService();

        $this->assertInstanceOf(QueueServiceInterface::class, $queueService);

    }

    /**

     * @return QueueServiceInterface

     */

    protected function getQueueServiceMock()

    {

        $queueServiceMock = $this->getMockBuilder(QueueServiceInterface::class)

            ->disableOriginalConstructor()

            ->getMock();

        $queueServiceMock->method('handle')

            ->willReturn('');

        return $queueServiceMock;

    }

}

use Cmobi\RabbitmqBundle\Tests\BaseTestCase;

use Cmobi\RabbitmqBundle\Transport\Worker\WorkerQueueCallback;

class WorkerQueueCallbackTest extends BaseTestCase

{

    public function testGetQueueService()

    {

        $rpcQueueCallback = new WorkerQueueCallback($this->getQueueServiceMock());

        $queueService = $rpcQueueCallback->getQueueService();

        $this->assertInstanceOf(QueueServiceInterface::class, $queueService);

    }

    /**

     * @return QueueServiceInterface

     */

    protected function getQueueServiceMock()

    {

        $queueServiceMock = $this->getMockBuilder(QueueServiceInterface::class)

            ->disableOriginalConstructor()

            ->getMock();

        $queueServiceMock->method('handle')

            ->willReturn('');

        return $queueServiceMock;

    }

}