rename start method
This commit is contained in:
@@ -110,7 +110,7 @@ class DataHandler {
|
|||||||
/**
|
/**
|
||||||
* Called to start the @a DataHandler.
|
* Called to start the @a DataHandler.
|
||||||
*/
|
*/
|
||||||
virtual void start() = 0;
|
virtual void startHandler() = 0;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Return whether this is a @a DataSink instance.
|
* Return whether this is a @a DataSink instance.
|
||||||
|
|||||||
@@ -231,7 +231,7 @@ void MainLoop::run() {
|
|||||||
if (dataHandler->isDataSink()) {
|
if (dataHandler->isDataSink()) {
|
||||||
dataSinks.push_back(dynamic_cast<DataSink*>(dataHandler));
|
dataSinks.push_back(dynamic_cast<DataSink*>(dataHandler));
|
||||||
}
|
}
|
||||||
dataHandler->start();
|
dataHandler->startHandler();
|
||||||
}
|
}
|
||||||
while (!m_shutdown) {
|
while (!m_shutdown) {
|
||||||
// pick the next message to handle
|
// pick the next message to handle
|
||||||
|
|||||||
@@ -1171,7 +1171,7 @@ MqttHandler::~MqttHandler() {
|
|||||||
mosquitto_lib_cleanup();
|
mosquitto_lib_cleanup();
|
||||||
}
|
}
|
||||||
|
|
||||||
void MqttHandler::start() {
|
void MqttHandler::startHandler() {
|
||||||
if (m_mosquitto) {
|
if (m_mosquitto) {
|
||||||
WaitThread::start("MQTT");
|
WaitThread::start("MQTT");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -281,7 +281,7 @@ class MqttHandler : public DataSink, public DataSource, public WaitThread {
|
|||||||
virtual ~MqttHandler();
|
virtual ~MqttHandler();
|
||||||
|
|
||||||
// @copydoc
|
// @copydoc
|
||||||
void start() override;
|
void startHandler() override;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Notify the handler of a (re-)established connection to the broker.
|
* Notify the handler of a (re-)established connection to the broker.
|
||||||
|
|||||||
Reference in New Issue
Block a user