def setup_exchange(self, exchange_name):
        """
        Setup the exchange on RabbitMQ by invoking the Exchange.Declare RPC
        command. When it is complete, the on_exchange_declareok method will
        be invoked by pika.

        :param str|unicode exchange_name: The name of the exchange to declare
        """
        self._logger.debug('Declaring exchange %s' % exchange_name)
        try:
            self._channel.exchange_declare(self.on_exchange_declareok,
                                           exchange_name,
                                           self._exchange_type)
        except Exception as e:
            self._logger.exception(e)
def setup_exchange ( self , exchange_name ) : self . _logger . debug ( 'Declaring exchange %s' % exchange_name ) try : self . _channel . exchange_declare ( self . on_exchange_declareok , exchange_name , self . _exchange_type ) except Exception as e : self . _logger . exception ( e )
Setup the exchange on RabbitMQ by invoking the Exchange.Declare RPC
        command. When it is complete, the on_exchange_declareok method will
        be invoked by pika.

        :param str|unicode exchange_name: The name of the exchange to declare