def METHOD_NAME(self):
    self.logger.info('AMQP Connecting to %s:%s/%s.',
                     self.connection_host, self.connection_port, self.connection_vhost)
    try:
        self._connection = pika.BlockingConnection(self.connection_parameters)
    except pika.exceptions.ProbableAuthenticationError:
        self.logger.error('AMQP authentication failed!')
        raise
    except pika.exceptions.ProbableAccessDeniedError:
        self.logger.error('AMQP authentication for virtual host failed!')
        raise
    except pika.exceptions.AMQPConnectionError:
        self.logger.error('AMQP connection failed!')
        raise
    else:
        self.logger.info('AMQP connection successful.')
        self.channel = self._connection.channel()
        if self.exchange_name:  # do not declare default exchange (#1295)
            try:
                self.channel.exchange_declare(exchange=self.exchange_name,
                                              exchange_type=self.exchange_type,
                                              durable=self.exchange_durable)
            except pika.exceptions.ChannelClosed:
                self.logger.error('Access to exchange refused.')
                raise
        self.channel.confirm_delivery()