Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit8ef1a1e

Browse files
committed
#547 Fixed up some of the v5 examples for proper connect options
1 parent6a1c354 commit8ef1a1e

File tree

5 files changed

+5
-9
lines changed

5 files changed

+5
-9
lines changed

‎examples/async_consume_v5.cpp‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,6 @@ using namespace std;
4343
const string DFLT_SERVER_URI{"mqtt://localhost:1883"};
4444
const string CLIENT_ID{"PahoCppAsyncConsumeV5"};
4545

46-
// const string TOPIC{"hello"};
4746
const string TOPIC{"#"};
4847
constint QOS =1;
4948

‎examples/async_subscribe_v5.cpp‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -193,9 +193,7 @@ int main(int argc, char* argv[])
193193

194194
mqtt::async_clientcli(serverURI, CLIENT_ID);
195195

196-
auto connOpts =mqtt::connect_options_builder::v5()
197-
.clean_start(true)
198-
.finalize();
196+
auto connOpts =mqtt::connect_options_builder::v5().clean_start(true).finalize();
199197

200198
// Install the callback(s) before connecting.
201199
callbackcb(cli, connOpts);

‎examples/mqttpp_chat.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ int main(int argc, char* argv[])
7676

7777
// Set up the connect options
7878

79-
auto connOpts =mqtt::connect_options_builder()
79+
auto connOpts =mqtt::connect_options_builder::v5()
8080
.properties({{mqtt::property::SESSION_EXPIRY_INTERVAL,604800}})
8181
.clean_start(false)
8282
.will(std::move(lwt))

‎examples/rpc_math_srvr.cpp‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -90,10 +90,9 @@ double mult(const std::vector<double>& nums)
9090

9191
intmain(int argc,char* argv[])
9292
{
93-
mqtt::create_optionscreateOpts(MQTTVERSION_5);
94-
mqtt::clientcli(SERVER_ADDRESS, CLIENT_ID, createOpts);
93+
mqtt::clientcli(SERVER_ADDRESS, CLIENT_ID);
9594

96-
auto connOpts =mqtt::connect_options_builder()
95+
auto connOpts =mqtt::connect_options_builder::v5()
9796
.keep_alive_interval(seconds(20))
9897
.clean_start()
9998
.finalize();

‎examples/sync_consume_v5.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ int main(int argc, char* argv[])
8484
{
8585
auto serverURI = (argc >1) ? std::string{argv[1]} : DFLT_SERVER_URI;
8686

87-
mqtt::clientcli(serverURI, CLIENT_ID,mqtt::create_options(MQTTVERSION_5));
87+
mqtt::clientcli(serverURI, CLIENT_ID);
8888

8989
auto connOpts =mqtt::connect_options_builder::v5()
9090
.automatic_reconnect(seconds(2),seconds(30))

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp