67 Commits

Author SHA1 Message Date
Igor Kulikov
d9311adfce Merge branch 'master' into rc 2025-07-24 12:46:37 +03:00
Artem Barysh
80061bb7c3 Fixed 2025-07-23 13:22:46 +03:00
Viacheslav Klimov
d494a8883a
Merge pull request #13735 from thingsboard/rc
rc
2025-07-18 11:57:46 +03:00
Andrii Landiak
3e223ed8bf Max client id for different mqtt protocol version 2025-07-15 10:31:54 +03:00
Sergey Matvienko
480b89c11c Reduced log severity to debug for Scheduling reconnect message to avoid log flood under high-load. Logs are made more informative. 2025-07-12 10:16:09 +02:00
Artem Barysh
9786e0a2f8 Resolved PR comments 2025-06-02 16:21:35 +03:00
Artem Barysh
e112077cb0 fixed 2025-05-29 13:52:08 +03:00
Artem Barysh
0bbec75e75 Fixed channel disconnection 2025-05-28 18:16:54 +03:00
Viacheslav Klimov
3194d8dea3
Merge pull request #12981 from smatvienko-tb/feature/mqtt-client-reconnect-strategy-exponential
MQTT client exponential reconnect strategy
2025-05-09 12:42:25 +03:00
Dmytro Skarzhynets
8d749f593b
MQTT client: limit retransmission attempts to prevent unlimited memory usage and network overload 2025-05-01 16:30:41 +03:00
Sergey Matvienko
5a46a170e4 MQTT client log added: Scheduling reconnect in [{}] sec 2025-04-16 16:47:20 +02:00
Sergey Matvienko
83790fa0fb ReconnectStrategyExponential jitter, max added, refactored, tested 2025-03-20 11:02:52 +01:00
Sergey Matvienko
264775ddb4 MQTT client reconnect strategy exponential 2025-03-19 20:58:09 +01:00
Igor Kulikov
5cf26d4851 Update license header 2025-02-25 09:39:16 +02:00
Andrew Shvayka
0192aed991
Merge branch 'master' into master 2024-09-09 17:56:44 +03:00
Andrii Landiak
5ca6ad03e3 CE: optimize java imports 2024-08-01 11:12:10 +03:00
imbeacon
764de2c8d6 Imports and refactoring 2024-05-07 18:12:42 +03:00
imbeacon
03ca18b64b Added MQTT reason codes from netty library 2024-05-07 17:12:59 +03:00
Sergey Matvienko
a1c226ae17 @ResourceLock("port8885") added for MQTT test with server on port 8885 2024-04-30 22:40:45 +02:00
Oleksandra Matviienko
f83ffa0990 removed unused classpath suite
Signed-off-by: Oleksandra Matviienko <al.zzzeebra@gmail.com>
2024-04-30 22:02:13 +02:00
Oleksandra Matviienko
1e581ffea4 JUnit5 migration in netty-mqtt. Junit-platform.properties and logback-test.xml where added to java resource directory.
Signed-off-by: Oleksandra Matviienko <al.zzzeebra@gmail.com>
2024-04-30 21:41:09 +02:00
YevhenBondarenko
d2961e39e7 merge with master 2024-02-06 22:40:27 +01:00
Andrii Shvaika
f0a9948cda Merge branch 'hotfix/3.6.2' 2024-02-06 19:21:57 +02:00
Sergey Matvienko
89713558cf MqttClient use Promise<V> extends Future<V> to have full async capabilities provided by Netty (addListener, etc) 2024-01-28 21:02:38 +01:00
YevhenBondarenko
60be820915 merge with master 2024-01-15 18:51:00 +01:00
Igor Kulikov
c5a72ed8df Update license header to 2024 year. 2024-01-09 10:46:16 +02:00
Andrii Shvaika
e768afc948 Merge 3.6 -> 3.7 2023-09-28 12:20:06 +03:00
chenggwang
9efec4755a
CompletableFuture compliant scheduling tasks
CompletableFuture compliant scheduling tasks
2023-09-27 23:21:39 +08:00
Andrii Shvaika
344ffb2e0b Merge with master 2023-08-14 15:02:17 +03:00
Sergey Matvienko
ed6614af71 MqttClientConfig - ownerId added for exceptions logging purposes. MqttChannelHandler - improved logging 2023-07-27 20:59:58 +02:00
Sergey Matvienko
d74e0c45df MqttHandler - processAsync (required for AbstractMqttIntegration) 2023-07-26 12:19:33 +02:00
Sergey Matvienko
7e27c5b683 mqtt-client: messages processing moved from netty event loop pool and to the handlerExecutor to make netty handlers non-blocking 2023-07-26 12:10:06 +02:00
YevhenBondarenko
7f9a9c7fb3 merge with develop/3.6 2023-06-05 15:58:16 +02:00
YevhenBondarenko
db6f310284 migration to spring boot 3.1 2023-06-05 15:24:47 +02:00
Andrii Landiak
6426dc4f6b MqttChannelHandler: add decoderResult check before casting to prevent class cast exception 2023-05-26 10:28:12 +03:00
YevhenBondarenko
fbf9773a61 optimize imports 2023-05-02 10:57:58 +02:00
dlandiak
cf9159db26 mqtt integration test improved 2023-03-02 15:46:50 +02:00
Igor Kulikov
cbdc4517e4 Update license header year to 2023 2023-01-31 10:43:56 +02:00
Dima Landiak
60ee2bb6ea netty tests - added custom mqtt server and test with keepalive logic 2022-08-01 14:57:16 +03:00
Dima Landiak
d6244a8422 netty client - added channel reader idle state handling, fixed ping/pong keepalive logic 2022-07-12 12:33:16 +03:00
towfiq
59f18b0e02 fix: typo fix in variable name and method name 2022-05-31 14:18:02 +06:00
Igor Kulikov
da4c742872 Update license year to 2022 2022-01-17 14:07:46 +02:00
Andrii Shvaika
0468cf8cf5 Fix duplication of MQTT packets in MQTT Client 2021-11-08 17:20:38 +02:00
zbeacon
06f199b936 Added stopping for subscriptions handlers and for unsubscription handlers 2021-11-08 14:38:14 +02:00
zbeacon
e7c4e76851 Added removing for timers in pendingPublishes on channel is closed 2021-11-08 14:38:14 +02:00
zbeacon
037d1797ac Fix for mqtt duplication sending on sent failed 2021-11-08 14:38:14 +02:00
vzikratyi
eec4f5a403 Removed unnecessary retain of PUBLISH message for QoS 2 2021-06-15 17:36:39 +03:00
Igor Kulikov
d31358b2ea Update license header - set 2021 year 2021-01-11 13:42:16 +02:00
zbeacon
444af2e57b Refactoring 2020-10-21 11:25:14 +03:00
zbeacon
ce591f9b38 Refactoring 2020-10-20 08:50:31 +03:00