def publish_callback():
    _LOGGER.debug('publish_debounced: publishing %s', msg)
    self._pending_messages.pop(msg)
    self.publish(msg.topic, msg.payload, qos=msg.qos, retain=msg.retain)
def publish_callback():
    _LOGGER.debug('publish_debounced: publishing %s', msg)
    self._pending_messages.pop(msg)
    self.publish(msg.topic, msg.payload, qos=msg.qos, retain=msg.retain)