komby enforce bind

komby.py

  def _create_exchange(self):
      return kombu.Exchange(self._amqp_exchange_name, type='direct',
                            durable=True, auto_delete=False)

  def _create_queue(self, exchange):
      return kombu.Queue(self._queue_name, auto_delete=False)

  def _enforce_bind(self):

      with kombu.Connection(host) as connection:
          exchange = self._create_exchange()(connection)
          exchange.declare()

          self._queue = self._create_queue(exchange)(connection)
          self._queue.declare()

          for routing_key in self._routing_keys:
              self._queue.bind_to(exchange, routing_key)