boostorg/mqtt5
1
0
Fork 1
mirror of https://github.com/boostorg/mqtt5.git synced 2025-07-30 12:37:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

update README

Browse Source 
Summary: related to T12804

Reviewers: iljazovic

Reviewed By: iljazovic

Subscribers: miljen

Differential Revision: https://repo.mireo.local/D26715
This commit is contained in:
Korina Šimičević
2023-11-27 10:14:47 +01:00
parent 0eaa9d7235
commit a0edbdabf2
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
README.md
View File

@ -40,7 +40,7 @@ Using the library
2. If you use SSL, download [OpenSSL](https://www.openssl.org/), link the library and add it to your include path. 2. If you use SSL, download [OpenSSL](https://www.openssl.org/), link the library and add it to your include path.
3. Additionally, you can add Async.MQTT5's `include` folder to your include path. 3. Additionally, you can add Async.MQTT5's `include` folder to your include path.
You can compile the example below with the following command line: You can compile the example below with the following command line on Linux:
$ clang++ -std=c++20 <source-cpp-file> -o example -I<path-to-boost> -Iinclude -pthread $ clang++ -std=c++20 <source-cpp-file> -o example -I<path-to-boost> -Iinclude -pthread
@ -64,15 +64,16 @@ int main() {
using client_type = async_mqtt5::mqtt_client<boost::asio::ip::tcp::socket>; using client_type = async_mqtt5::mqtt_client<boost::asio::ip::tcp::socket>;
client_type c(ioc, ""); client_type c(ioc, "");
c.credentials("clientid", "", "") c.credentials("clientid", "username", "password")
.brokers("mqtt.broker", 1883) .brokers("mqtt.broker", 1883)
.run(); .run();
c.async_publish<async_mqtt5::qos_e::at_most_once>( c.async_publish<async_mqtt5::qos_e::at_most_once>(
"test/mqtt-test", "hello world!", "test/mqtt-test", "hello world!",
async_mqtt5::retain_e::no, async_mqtt5::publish_props {}, async_mqtt5::retain_e::no, async_mqtt5::publish_props {},
[](async_mqtt5::error_code ec) { [&c](async_mqtt5::error_code ec) {
std::cout << ec.message() << std::endl; std::cout << ec.message() << std::endl;
c.cancel(); // close the client
} }
); );