From 34cfa6125722d1364e1cfe3893da2bf5d7f8b225 Mon Sep 17 00:00:00 2001 From: "ishak jmilou.ishak" Date: Tue, 22 Oct 2024 12:16:40 +0200 Subject: [PATCH] changed version op mqtt --- src/C++/Socket/main.cpp | 50 +++++++++++++++++++++-------------------- 1 file changed, 26 insertions(+), 24 deletions(-) diff --git a/src/C++/Socket/main.cpp b/src/C++/Socket/main.cpp index d70eaf3..999669a 100644 --- a/src/C++/Socket/main.cpp +++ b/src/C++/Socket/main.cpp @@ -6,37 +6,39 @@ const std::string CLIENT_ID("raspberry_pi_client"); const std::string TOPIC("home/commands"); class callback : public virtual mqtt::callback { - void message_arrived(mqtt::const_message_ptr msg) override { - std::cout << "Ontvangen bericht: '" << msg->get_topic() << "' : " << msg->to_string() << std::endl; - // Doe iets met het bericht, bijvoorbeeld een GP.IO-activering - } + void message_arrived(mqtt::const_message_ptr msg) override { + std::cout << "Ontvangen bericht: '" << msg->get_topic() + << "' : " << msg->to_string() << std::endl; + // Doe iets met het bericht, bijvoorbeeld een GP.IO-activering + } }; int main() { - mqtt::async_client client(ADDRESS, CLIENT_ID); - callback cb; - client.set_callback(cb); + mqtt::async_client client(ADDRESS, CLIENT_ID); + callback cb; + client.set_callback(cb); - mqtt::connect_options connOpts; - connOpts.set_clean_session(true); - connOpts.set_user_name("ishak"); - connOpts.set_password("kobuki"); + mqtt::connect_options connOpts; + connOpts.set_clean_session(true); + connOpts.set_user_name("ishak"); + connOpts.set_password("kobuki"); + connOpts.set_mqtt_version(MQTTVERSION_5); // Stel de MQTT-versie in (bijv. MQTT 5.0) - try { - std::cout << "Verbinden met broker..." << std::endl; - client.connect(connOpts)->wait(); - std::cout << "Verbonden!" << std::endl; + try { + std::cout << "Verbinden met broker..." << std::endl; + client.connect(connOpts)->wait(); + std::cout << "Verbonden!" << std::endl; - std::cout << "Abonneren op topic: " << TOPIC << std::endl; - client.subscribe(TOPIC, 1)->wait(); + std::cout << "Abonneren op topic: " << TOPIC << std::endl; + client.subscribe(TOPIC, 1)->wait(); - while (true) { - // Houd de client draaiende om berichten te blijven ontvangen - } - } catch (const mqtt::exception& exc) { - std::cerr << exc.what() << std::endl; - return 1; + while (true) { + // Houd de client draaiende om berichten te blijven ontvangen } + } catch (const mqtt::exception &exc) { + std::cerr << exc.what() << std::endl; + return 1; + } - return 0; + return 0; } \ No newline at end of file