style
This commit is contained in:
@@ -555,7 +555,7 @@ void MqttHandler::run() {
|
|||||||
if (!m_updatedMessages.empty()) {
|
if (!m_updatedMessages.empty()) {
|
||||||
if (m_connected) {
|
if (m_connected) {
|
||||||
m_messages->lock();
|
m_messages->lock();
|
||||||
for(auto it = m_updatedMessages.begin(); it != m_updatedMessages.end(); ) {
|
for (auto it = m_updatedMessages.begin(); it != m_updatedMessages.end(); ) {
|
||||||
const vector<Message*>* messages = m_messages->getByKey(it->first);
|
const vector<Message*>* messages = m_messages->getByKey(it->first);
|
||||||
if (messages) {
|
if (messages) {
|
||||||
updates.str("");
|
updates.str("");
|
||||||
|
|||||||
@@ -22,6 +22,7 @@
|
|||||||
#include <mosquitto.h>
|
#include <mosquitto.h>
|
||||||
#include <map>
|
#include <map>
|
||||||
#include <string>
|
#include <string>
|
||||||
|
#include <list>
|
||||||
#include <vector>
|
#include <vector>
|
||||||
#include "ebusd/datahandler.h"
|
#include "ebusd/datahandler.h"
|
||||||
#include "ebusd/bushandler.h"
|
#include "ebusd/bushandler.h"
|
||||||
|
|||||||
Reference in New Issue
Block a user