mirror of
https://github.com/Relintai/rcpp_sample_simple_data_collector_app.git
synced 2025-04-23 03:11:19 +02:00
Update the engine., and init an mqtt broken in main.
This commit is contained in:
parent
a73ff4e05c
commit
c271d9cf41
2
HEADS
2
HEADS
@ -1 +1 @@
|
||||
{"engine": {"master": "8c483b4f8ee02bebb9db275a262208254f0d34fc"}}
|
||||
{"engine": {"master": "09e13d255cee057e788b2acceec896a2e86df615"}}
|
10
main.cpp
10
main.cpp
@ -14,6 +14,8 @@
|
||||
|
||||
#include "core/settings.h"
|
||||
|
||||
#include "modules/mqtt_server/mqtt_server.h"
|
||||
|
||||
#define MAIN_CLASS RDNApplication
|
||||
|
||||
void create_databases() {
|
||||
@ -25,7 +27,7 @@ void create_databases() {
|
||||
return;
|
||||
}
|
||||
|
||||
/*
|
||||
/*
|
||||
rapidjson::Value dbs = settings->settings["databases"];
|
||||
|
||||
if (!dbs.IsArray()) {
|
||||
@ -79,14 +81,20 @@ int main(int argc, char **argv) {
|
||||
server->port = 8080;
|
||||
server->initialize();
|
||||
|
||||
MQTTServer *mqtt_server = new MQTTServer();
|
||||
mqtt_server->initialize();
|
||||
|
||||
if (!migrate) {
|
||||
printf("Initialized!\n");
|
||||
|
||||
mqtt_server->run_async();
|
||||
server->main_loop();
|
||||
} else {
|
||||
printf("Running migrations.\n");
|
||||
app->migrate();
|
||||
}
|
||||
|
||||
delete mqtt_server;
|
||||
delete server;
|
||||
delete app;
|
||||
delete dbm;
|
||||
|
Loading…
Reference in New Issue
Block a user