docs: def ack_message(self, message):
          """Acknowledge the message on the broker and log the ack
  
          :param message: The message to acknowledge
          :type message: rejected.data.Message
  
          """
          if message.channel.is_closed:
              LOGGER.warning('Can not ack message, channel is closed')
              self.counters[self.CLOSED_ON_COMPLETE] += 1
              return
          message.channel.basic_ack(delivery_tag=message.delivery_tag)
          self.counters[self.ACKED] += 1
          self.measurement.set_tag(self.ACKED, True)