! *\brief Reads every message from the message puffer */
| 153 | *\brief Reads every message from the message puffer |
| 154 | */ |
| 155 | void MQTTTopic::read() { |
| 156 | while (!m_messagePuffer.isEmpty()) { |
| 157 | qDebug() << "Reading from topic " << m_topicName; |
| 158 | auto msg = m_messagePuffer.takeFirst(); |
| 159 | BufferReader reader(msg.payload()); |
| 160 | m_filter |
| 161 | ->readFromDevice(reader, AbstractFileFilter::ImportMode::Replace, AbstractFileFilter::ImportMode::Append, 0, -1, this->mqttClient()->keepNValues()); |
| 162 | } |
| 163 | } |
| 164 | |
| 165 | // ############################################################################## |
| 166 | // ################## Serialization/Deserialization ########################### |