public function createQueue($queueName)
    {
        $channel = $this->getChannel();
        $channel->exchange_declare($this->exchange, 'direct', false, true, false);
        $channel->queue_declare($queueName, false, true, false, false);
        $channel->queue_bind($queueName, $this->exchange, $queueName);
    }
public function createQueue($queueName)
    {
        $channel = $this->getChannel();
        $channel->exchange_declare($this->exchange, 'direct', false, true, false);
        $channel->queue_declare($queueName, false, true, false, false);
        $channel->queue_bind($queueName, $this->exchange, $queueName);
    }
public function createQueue ( $ queueName ) { $ channel = $ this -> getChannel ( ) ; $ channel -> exchange_declare ( $ this -> exchange , 'direct' , false , true , false ) ; $ channel -> queue_declare ( $ queueName , false , true , false , false ) ; $ channel -> queue_bind ( $ queueName , $ this -> exchange , $ queueName ) ; }
Create a queue.

@param string $queueName
Create a queue .