5b5b4dff6b
Update license header
1 month ago
80061bb7c3
Fixed
7 months ago
3e223ed8bf
Max client id for different mqtt protocol version
7 months ago
480b89c11c
Reduced log severity to debug for Scheduling reconnect message to avoid log flood under high-load. Logs are made more informative.
7 months ago
9786e0a2f8
Resolved PR comments
8 months ago
e112077cb0
fixed
8 months ago
0bbec75e75
Fixed channel disconnection
8 months ago
8d749f593b
MQTT client: limit retransmission attempts to prevent unlimited memory usage and network overload
11 months ago
5a46a170e4
MQTT client log added: Scheduling reconnect in [{}] sec
10 months ago
83790fa0fb
ReconnectStrategyExponential jitter, max added, refactored, tested
11 months ago
264775ddb4
MQTT client reconnect strategy exponential
11 months ago
5cf26d4851
Update license header
12 months ago
5ca6ad03e3
CE: optimize java imports
2 years ago
764de2c8d6
Imports and refactoring
2 years ago
03ca18b64b
Added MQTT reason codes from netty library
2 years ago
a1c226ae17
@ResourceLock("port8885") added for MQTT test with server on port 8885
2 years ago
f83ffa0990
removed unused classpath suite
Signed-off-by: Oleksandra Matviienko <al.zzzeebra@gmail.com>
2 years ago
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>
2 years ago
89713558cf
MqttClient use Promise<V> extends Future<V> to have full async capabilities provided by Netty (addListener, etc)
2 years ago
09fc025e12
Initial commit from another fork
2 years ago
c5a72ed8df
Update license header to 2024 year.
2 years ago
9efec4755a
CompletableFuture compliant scheduling tasks
CompletableFuture compliant scheduling tasks
2 years ago
ed6614af71
MqttClientConfig - ownerId added for exceptions logging purposes. MqttChannelHandler - improved logging
3 years ago
d74e0c45df
MqttHandler - processAsync (required for AbstractMqttIntegration)
3 years ago
7e27c5b683
mqtt-client: messages processing moved from netty event loop pool and to the handlerExecutor to make netty handlers non-blocking
3 years ago
db6f310284
migration to spring boot 3.1
3 years ago
6426dc4f6b
MqttChannelHandler: add decoderResult check before casting to prevent class cast exception
3 years ago
fbf9773a61
optimize imports
3 years ago
29c3eddc8a
Merge with branch 'develop/3.5' of github.com:thingsboard/thingsboard
3 years ago
cf9159db26
mqtt integration test improved
3 years ago
cbdc4517e4
Update license header year to 2023
3 years ago
60ee2bb6ea
netty tests - added custom mqtt server and test with keepalive logic
4 years ago
d6244a8422
netty client - added channel reader idle state handling, fixed ping/pong keepalive logic
4 years ago
59f18b0e02
fix: typo fix in variable name and method name
4 years ago
da4c742872
Update license year to 2022
4 years ago
0468cf8cf5
Fix duplication of MQTT packets in MQTT Client
4 years ago
06f199b936
Added stopping for subscriptions handlers and for unsubscription handlers
4 years ago
e7c4e76851
Added removing for timers in pendingPublishes on channel is closed
4 years ago
037d1797ac
Fix for mqtt duplication sending on sent failed
4 years ago
eec4f5a403
Removed unnecessary retain of PUBLISH message for QoS 2
5 years ago
d31358b2ea
Update license header - set 2021 year
5 years ago
444af2e57b
Refactoring
5 years ago
ce591f9b38
Refactoring
5 years ago
9cdf3dd80c
Improvements in MQTT publish processing
5 years ago
2e694e1d64
Dao layer for UsageRecords
5 years ago
8e8c1ae860
Removed resending of PUBREC msgs
6 years ago
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
6 years ago
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
6 years ago
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.
6 years ago
3e2a87135f
Prepare for merge with master
6 years ago
Viacheslav Klimov
Artem Barysh
Andrii Landiak
Sergey Matvienko
Dmytro Skarzhynets
Igor Kulikov
imbeacon
Oleksandra Matviienko
Ivan Raznatovskyi
chenggwang
YevhenBondarenko
Seraphym-Tuhai
dlandiak
towfiq
Andrii Shvaika
vzikratyi
blackstar-baba