thecodingmachine / oo-amqp-client

        new Exchange($client, '', 'direct');

    }

    public function testDefaultExchange()

    {

        $client = $this->makeClient();

        // Let's send a message on RabbitMQ default exchange (named "")

        $exchange = new DefaultExchange($client);

        $queue = new Queue($client, 'test_direct_queue', [

            new Consumer(function(AMQPMessage $msg) {

                $this->msgReceived = $msg;

            }, new NullLogger())

        ]);

        // The key is the name of the queue.

        $exchange->publish(new Message('hello'), 'test_direct_queue');

        $consumerService = new ConsumerService($client, [

            $queue

        ]);

        $consumerService->run(true);

        $this->assertEquals('hello', $this->msgReceived->getBody());

    }

    public function testPublishToQueue()

    {

        $this->assertEquals('hello', $this->msgReceived->getBody());

    }

    public function testPublishToQueue()

    {

        $client = $this->makeClient();

        $queue = new Queue($client, 'test_direct_queue', [

            new Consumer(function (AMQPMessage $msg) {

                $this->msgReceived = $msg;

            }, new NullLogger())

        ]);

        // The key is the name of the queue.

        $queue->publish(new Message('hello'));

        $consumerService = new ConsumerService($client, [

            $queue

        ]);

        $consumerService->run(true);

        $this->assertEquals('hello', $this->msgReceived->getBody());

    }

    /**

     * @expectedException \Mouf\AmqpClient\Exception\ConnectionException