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
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
