phpservicebus / core

     *

     * @return AMQPExchange

     */

    private function produceExchangeInstance($exchangeName)

    {

        if (isset($this->declaredExchangeInstances[$exchangeName])) {

            return $this->declaredExchangeInstances[$exchangeName];

        }

        if (isset($this->usedExchangeInstances[$exchangeName])) {

            return $this->usedExchangeInstances[$exchangeName];

        }

        $this->ensureChannel();

        $exchange = new AMQPExchange($this->channel);

        $exchange->setName($exchangeName);

        $this->usedExchangeInstances[$exchangeName] = $exchange;

        return $exchange;

    }

    /**

     * It returns a cached queue or a new one if none exists.

     *

     * @return AMQPQueue

     */

    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 ensureChannel()

    {