contamobi / CmobiRabbitmqBundle

        $this->assertInstanceOf(ConnectionManager::class, $connectionManager);

    }

    public function testBuildQueue()

    {

        $subscriberBuilder = new SubscriberBuilder(

            'test',

            ExchangeType::FANOUT,

            $this->getConnectionManagerMock(),

            $this->getLoggerMock(),

            []

        );

        $queue = $subscriberBuilder->buildQueue('test', $this->getQueueServiceMock());

        $this->assertInstanceOf(QueueInterface::class, $queue);

    }

    public function testGetExchange()

    {

        $this->assertInstanceOf(ConnectionManager::class, $connectionManager);

    }

    public function testBuildQueue()

    {

        $rpcServer = new RpcServerBuilder($this->getConnectionManagerMock(), $this->getLoggerMock(), []);

        $queue = $rpcServer->buildQueue('test', $this->getQueueServiceMock());

        $this->assertInstanceOf(QueueInterface::class, $queue);

    }

    public function testGetCallbackAfterBuildQueue()

    {

        $this->assertInstanceOf(QueueInterface::class, $queue);

    }

    public function testGetCallbackAfterBuildQueue()

    {

        $rpcServer = new RpcServerBuilder($this->getConnectionManagerMock(), $this->getLoggerMock(), []);

        $queue = $rpcServer->buildQueue('test', $this->getQueueServiceMock());

        $callback = $queue->getCallback();

        $this->assertInstanceOf(QueueCallbackInterface::class, $callback);

    }

    /**

     * @return CmobiAMQPConnectionInterface

        $this->assertInstanceOf(ConnectionManager::class, $connectionManager);

    }

    public function testBuildQueue()

    {

        $workerServer = new WorkerBuilder($this->getConnectionManagerMock(), $this->getLoggerMock(), []);

        $queue = $workerServer->buildQueue('test', $this->getQueueServiceMock());

        $this->assertInstanceOf(QueueInterface::class, $queue);

    }

    /**

     * @return CmobiAMQPConnectionInterface