kakserpom / phpdaemon

     * @throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException

     * @throws \PHPDaemon\Clients\AMQP\Driver\Exception\AMQPChannelException

     */

    public function bindExchange($name, $exchangeName, $routingKey, array $options = [], callable $callback = null)

    {

        if (!$this->connection->getFeatures()->exchangeToExchangeBindings) {

            throw new AMQPChannelException('Broker does not support exchange to exchange bindings');

        }

        if ($exchangeName === $name) {

            throw new AMQPChannelException('Exchange cannot bind to itself');

        }

        $noWait = array_key_exists('noWait', $options) ? $options['noWait'] : false;

        $outputFrame = Exchange\ExchangeBindFrame::create(

            $name,

            $exchangeName,

            $routingKey,

            $noWait,

            $options

        );

        $outputFrame->frameChannelId = $this->id;

        $this->connection->command($outputFrame);

        if (is_callable($callback)) {

            $this->on(self::EVENT_ON_CHANNEL_BIND_EXCHANGE_CALLBACK, $callback);

        }

    }

    /**

     * Unbind exchange

     * @throws \PHPDaemon\Clients\AMQP\Driver\Exception\AMQPChannelException

     * @throws \PHPDaemon\Clients\AMQP\Driver\Protocol\Exception\AMQPProtocolException

     */

    public function unbindExchange($name, $exchangeName, $routingKey, array $options = [], callable $callback = null)

    {

        if (!$this->connection->getFeatures()->exchangeToExchangeBindings) {

            throw new AMQPChannelException('Broker does not support exchange to exchange bindings');

        }

        if ($exchangeName === $name) {

            throw new AMQPChannelException('Exchange cannot unbind itself');

        }

        $noWait = array_key_exists('noWait', $options) ? $options['noWait'] : false;

        $outputFrame = Exchange\ExchangeUnbindFrame::create(

            $name,

            $exchangeName,

            $routingKey,

            $noWait,

            $options

        );

        $outputFrame->frameChannelId = $this->id;

        $this->connection->command($outputFrame);

        if (is_callable($callback)) {

            $this->on(self::EVENT_ON_CHANNEL_UNBIND_EXCHANGE_CALLBACK, $callback);

        }

    }

    /**

     * Publish message to exchange