33 Commits

Author SHA1 Message Date
YevhenBondarenko
db6f310284 migration to spring boot 3.1 2023-06-05 15:24:47 +02: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
zbeacon
9cdf3dd80c Improvements in MQTT publish processing 2020-10-19 16:43:39 +03:00
vzikratyi
8e8c1ae860 Removed resending of PUBREC msgs 2020-08-31 15:44:11 +03:00
blackstar-baba
7fd517dafa
Follow mqtt 3.1.1 protocol number 3.3.1-2
Follow mqtt 3.1.1 protocol number 3.3.1-2 : The DUP flag MUST be set to 0 for all QoS 0 messages. If the qos of the publish message is not 0, then set dup to true
2020-05-26 14:01:34 +08:00
blackstar-baba
dda3124835
fix bug: Resending the message causes the client to interrupt
In the mqtt 3.1 protocol or mqtt 3.1.1 protocol, except for messages of type pubish, the isDup of other messages must be zero,Sending a subscription message multiple times causes the client to reconnect,therefore, resending the subscription message with isDup true will cause the server to think that the message is abnormal, thus interrupting the connection with the client
2020-05-24 23:22:51 +08:00
blackstar-baba
00b5d36e0b
fix bug: Under high concurrency, Mqtt client nextMessageId exceeds the 0xffff limit (#2564)
The compareAndSet method and getAndIncrement method of the AtomicInteger class are atomic, but when these two methods are used at the same time, they are no longer atomic.
2020-04-01 09:39:51 +03:00
Igor Kulikov
850d6d948c Update License header year to 2020 2020-01-06 16:52:41 +02:00
Igor Kulikov
1265a9a1e3 Revert "Update License header year to 2020"
This reverts commit 9b42397c4a820688daf07117cb7efefa3f387f46.
2020-01-06 16:48:55 +02:00
Igor Kulikov
9b42397c4a Update License header year to 2020 2020-01-06 16:41:04 +02:00
Andrew Shvayka
3b52f9817d MessageId to PacketId refactoring 2019-03-25 18:00:39 +02:00
Igor Kulikov
ced63c4e70 Update License Header year to 2019 2019-02-01 16:39:33 +02:00
Valerii Sosliuk
5aced98ce3 Fix NPE in Netty-mqtt client (#1398)
* Fix NPE in netty-mqtt client on puback

* Fix gateway mqtt extension configuration - filter is not required
2019-01-16 17:17:50 +02:00
Andrew Shvayka
f5bd9a2133 Issue #1327 fixed 2018-12-27 13:12:59 +02:00
Igor Kulikov
b40a135a7e Fix NPE in MqttClient 2018-11-13 11:50:45 +02:00
Chi Joung So
44a1fa2911
ReconnectDelay and MaxBytesInMessage configurable 2018-08-23 10:02:28 +02:00
Igor Kulikov
309598c2ac subscribtion -> subscription typo fix. 2018-06-04 11:22:14 +03:00
Igor Kulikov
17adf8bd8b Improved MQTT client and added default handler to handle reconnect subscriptions 2018-06-04 11:06:42 +03:00
Igor Kulikov
0ea799d8e3 Add Netty MQTT Client module. 2018-05-14 11:20:24 +03:00