src/Transport/RabbitMq/BrokerModel.php
private function produceQueueInstance($queueName)
    {
        if (isset($this->declaredQueueInstances[$queueName])) {
            return $this->declaredQueueInstances[$queueName];
        }

        if (isset($this->usedQueueInstances[$queueName])) {
            return $this->usedQueueInstances[$queueName];
        }

        $this->ensureChannel();
        $queue = new AMQPQueue($this->channel);
        $queue->setName($queueName);
        $this->usedQueueInstances[$queueName] = $queue;
        return $queue;
    }
private function produceQueueInstance($queueName)
    {
        if (isset($this->declaredQueueInstances[$queueName])) {
            return $this->declaredQueueInstances[$queueName];
        }

        if (isset($this->usedQueueInstances[$queueName])) {
            return $this->usedQueueInstances[$queueName];
        }

        $this->ensureChannel();
        $queue = new AMQPQueue($this->channel);
        $queue->setName($queueName);
        $this->usedQueueInstances[$queueName] = $queue;
        return $queue;
    }
private function produceQueueInstance ( $ queueName ) { if ( isset ( $ this -> declaredQueueInstances [ $ queueName ] ) ) { return $ this -> declaredQueueInstances [ $ queueName ] ; } if ( isset ( $ this -> usedQueueInstances [ $ queueName ] ) ) { return $ this -> usedQueueInstances [ $ queueName ] ; } $ this -> ensureChannel ( ) ; $ queue = new AMQPQueue ( $ this -> channel ) ; $ queue -> setName ( $ queueName ) ; $ this -> usedQueueInstances [ $ queueName ] = $ queue ; return $ queue ; }
It returns a cached queue or a new one if none exists.

@param string $queueName

@return AMQPQueue
It returns a cached queue or a new one if none exists .