From 873d8b7133de4bf3d203722f86e76a63b764101b Mon Sep 17 00:00:00 2001 From: Steve Hamblett Date: Sat, 6 Sep 2025 08:47:25 +0100 Subject: [PATCH 1/3] Issue 622 --- test/issues/issue622.dart | 49 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 49 insertions(+) create mode 100644 test/issues/issue622.dart diff --git a/test/issues/issue622.dart b/test/issues/issue622.dart new file mode 100644 index 0000000..807929b --- /dev/null +++ b/test/issues/issue622.dart @@ -0,0 +1,49 @@ +/* + * Package : mqtt_client + * Author : S. Hamblett + * Date : 31/05/2017 + * Copyright : S.Hamblett + */ + +import 'package:mqtt_client/mqtt_server_client.dart'; + +void main() async { + final mqttClient1 = MqttServerClient( + 'test.mosquitto.org', + 'Unique_ID-1', + maxConnectionAttempts: 1, + ); + mqttClient1.logging(on: true); + mqttClient1.onConnected = onConnected1; + await mqttClient1.connect(); + + final mqttClient2 = MqttServerClient( + 'test.mosquitto.org', + 'Unique_ID-2', + maxConnectionAttempts: 1, + ); + mqttClient2.logging(on: true); + mqttClient2.onConnected = onConnected2; + await mqttClient2.connect(); + + final mqttClient3 = MqttServerClient( + 'test.mosquitto.org', + 'Unique_ID-3', + maxConnectionAttempts: 1, + ); + mqttClient3.logging(on: true); + mqttClient3.onConnected = onConnected3; + await mqttClient3.connect(); +} + +void onConnected1() { + print('Client 1 connected'); +} + +void onConnected2() { + print('Client 2 connected'); +} + +void onConnected3() { + print('Client 2 connected'); +} \ No newline at end of file From 2298eb4c90372f9a7c02042bfb402a68db4b8ead Mon Sep 17 00:00:00 2001 From: Steve Hamblett Date: Sat, 6 Sep 2025 09:07:02 +0100 Subject: [PATCH 2/3] Issue 622 --- test/issues/issue622.dart | 52 ++++++++++++++++++++++++++++++++++---- test/issues/issue622.zip | Bin 0 -> 644 bytes 2 files changed, 47 insertions(+), 5 deletions(-) create mode 100644 test/issues/issue622.zip diff --git a/test/issues/issue622.dart b/test/issues/issue622.dart index 807929b..ddb19a2 100644 --- a/test/issues/issue622.dart +++ b/test/issues/issue622.dart @@ -8,13 +8,18 @@ import 'package:mqtt_client/mqtt_server_client.dart'; void main() async { + bool logging = true; + final mqttClient1 = MqttServerClient( 'test.mosquitto.org', 'Unique_ID-1', maxConnectionAttempts: 1, ); - mqttClient1.logging(on: true); + mqttClient1.logging(on: logging); + mqttClient1.keepAlivePeriod = 3; mqttClient1.onConnected = onConnected1; + mqttClient1.onDisconnected = onDisconnected1; + mqttClient1.pongCallback = onPong1; await mqttClient1.connect(); final mqttClient2 = MqttServerClient( @@ -22,8 +27,11 @@ void main() async { 'Unique_ID-2', maxConnectionAttempts: 1, ); - mqttClient2.logging(on: true); + mqttClient2.logging(on: logging); + mqttClient2.keepAlivePeriod = 3; mqttClient2.onConnected = onConnected2; + mqttClient2.onDisconnected = onDisconnected2; + mqttClient2.pongCallback = onPong2; await mqttClient2.connect(); final mqttClient3 = MqttServerClient( @@ -31,9 +39,19 @@ void main() async { 'Unique_ID-3', maxConnectionAttempts: 1, ); - mqttClient3.logging(on: true); + mqttClient3.logging(on: logging); + mqttClient3.keepAlivePeriod = 3; mqttClient3.onConnected = onConnected3; + mqttClient3.onDisconnected = onDisconnected3; + mqttClient3.pongCallback = onPong3; await mqttClient3.connect(); + + await Future.delayed(Duration(seconds: 15)); + + print('Disconnecting clients'); + mqttClient1.disconnect(); + mqttClient2.disconnect(); + mqttClient3.disconnect(); } void onConnected1() { @@ -45,5 +63,29 @@ void onConnected2() { } void onConnected3() { - print('Client 2 connected'); -} \ No newline at end of file + print('Client 3 connected'); +} + +void onDisconnected1() { + print('Client 1 Disconnected'); +} + +void onDisconnected2() { + print('Client 2 Disconnected'); +} + +void onDisconnected3() { + print('Client 3 Disconnected'); +} + +void onPong1() { + print('Client 1 pong received.'); +} + +void onPong2() { + print('Client 2 pong received.'); +} + +void onPong3() { + print('Client 3 pong received.'); +} diff --git a/test/issues/issue622.zip b/test/issues/issue622.zip new file mode 100644 index 0000000000000000000000000000000000000000..b3ab8e7fba09861a902f3861669ae1bf94dbb80f GIT binary patch literal 644 zcmWIWW@Zs#U|`^2C~{YeZhO#pm4k_aVFx<{120fCv$(i4)y&99FD0?4Wa$+D{@Dfs zN8i_U?Q~ouCKkQgYspF})m68gmwH^B7tZI?DY~Ik@>1`ry6;`~yHy$UH{Ft+S9!kf zPl~@mX#!Wa;Ct6D0mnLpsvhIcu2;tvEt+d4aPV0Bd!_qn9xU^{4=MlJo%h#t@~Wy& z$#d&h>S{Z3FbIAy*s+`cM(mH3dite>Mn-o9T^OYQR~oY~YkYiS&xN)Fy0>Hk^<6L2 zOwZ`c*fnWBhx5BLg?&+K6S!CI;q3UdBn@u1V21e$WZ60y6GAF z^s{D)XC6Lp%((pK?ll{Bh6AcPC(oBwu27lyZL8;9{@mw|C!JgS?Ze~`uba}nd}$b0 z@}wx;4g>uaJql}fPoByASNN~qwB?~+WC|DDR2J*@kt^(Vd&TnXfWB%}se97hcWVzV zEK)uF!{?4Z&zIJ)mq95v!;buR+j~tbH{{Xw2_?(kmVH!PTygXFhfUibrhGPum|qHGlB*`o|*cdxB3_SFryI+*8A&zyHAPZ~H?- zB)|6jhc-Pd}aSNVq}lf`G6@96&~xBtc8 zw`y_!_f}6%dsbQ)CExO)>4fa}je+vJUp-!Im-l&Yuax(deaGHyW8HT)w>!7oJo)^j z9s5!f4BRS@9FhN(6S@9pj^^>2{|o`%j7;{-xDyR9-GIT8Mi7OPgaW)-*+7DfKxhr5 Kje%*6fdK$YnIXUc literal 0 HcmV?d00001 From 27fcb30a3c057849e51e1520f57663a71d3a274c Mon Sep 17 00:00:00 2001 From: Steve Hamblett Date: Sat, 6 Sep 2025 14:26:04 +0100 Subject: [PATCH 3/3] Issue 622 --- test/issues/{ => issue622}/issue622.dart | 0 test/issues/{ => issue622}/issue622.zip | Bin 2 files changed, 0 insertions(+), 0 deletions(-) rename test/issues/{ => issue622}/issue622.dart (100%) rename test/issues/{ => issue622}/issue622.zip (100%) diff --git a/test/issues/issue622.dart b/test/issues/issue622/issue622.dart similarity index 100% rename from test/issues/issue622.dart rename to test/issues/issue622/issue622.dart diff --git a/test/issues/issue622.zip b/test/issues/issue622/issue622.zip similarity index 100% rename from test/issues/issue622.zip rename to test/issues/issue622/issue622.zip