imbeacon
764de2c8d6
Imports and refactoring
2 years ago
imbeacon
03ca18b64b
Added MQTT reason codes from netty library
2 years ago
Sergey Matvienko
a1c226ae17
@ResourceLock("port8885") added for MQTT test with server on port 8885
2 years ago
Oleksandra Matviienko
f83ffa0990
removed unused classpath suite
Signed-off-by: Oleksandra Matviienko <al.zzzeebra@gmail.com>
2 years ago
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>
2 years ago
Sergey Matvienko
89713558cf
MqttClient use Promise<V> extends Future<V> to have full async capabilities provided by Netty (addListener, etc)
2 years ago
Ivan Raznatovskyi
09fc025e12
Initial commit from another fork
2 years ago
Igor Kulikov
c5a72ed8df
Update license header to 2024 year.
2 years ago
Sergey Matvienko
ed6614af71
MqttClientConfig - ownerId added for exceptions logging purposes. MqttChannelHandler - improved logging
3 years ago
Sergey Matvienko
d74e0c45df
MqttHandler - processAsync (required for AbstractMqttIntegration)
3 years ago
Sergey Matvienko
7e27c5b683
mqtt-client: messages processing moved from netty event loop pool and to the handlerExecutor to make netty handlers non-blocking
3 years ago
YevhenBondarenko
db6f310284
migration to spring boot 3.1
3 years ago
Andrii Landiak
6426dc4f6b
MqttChannelHandler: add decoderResult check before casting to prevent class cast exception
3 years ago
YevhenBondarenko
fbf9773a61
optimize imports
3 years ago
Seraphym-Tuhai
29c3eddc8a
Merge with branch 'develop/3.5' of github.com:thingsboard/thingsboard
3 years ago
dlandiak
cf9159db26
mqtt integration test improved
3 years ago
Igor Kulikov
cbdc4517e4
Update license header year to 2023
3 years ago
Dima Landiak
60ee2bb6ea
netty tests - added custom mqtt server and test with keepalive logic
4 years ago
Dima Landiak
d6244a8422
netty client - added channel reader idle state handling, fixed ping/pong keepalive logic
4 years ago
towfiq
59f18b0e02
fix: typo fix in variable name and method name
4 years ago
Igor Kulikov
da4c742872
Update license year to 2022
4 years ago
Andrii Shvaika
0468cf8cf5
Fix duplication of MQTT packets in MQTT Client
5 years ago
zbeacon
06f199b936
Added stopping for subscriptions handlers and for unsubscription handlers
5 years ago
zbeacon
e7c4e76851
Added removing for timers in pendingPublishes on channel is closed
5 years ago
zbeacon
037d1797ac
Fix for mqtt duplication sending on sent failed
5 years ago
vzikratyi
eec4f5a403
Removed unnecessary retain of PUBLISH message for QoS 2
5 years ago
Igor Kulikov
d31358b2ea
Update license header - set 2021 year
6 years ago
zbeacon
444af2e57b
Refactoring
6 years ago
zbeacon
ce591f9b38
Refactoring
6 years ago
zbeacon
9cdf3dd80c
Improvements in MQTT publish processing
6 years ago
Andrii Shvaika
2e694e1d64
Dao layer for UsageRecords
6 years ago
vzikratyi
8e8c1ae860
Removed resending of PUBREC msgs
6 years ago
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
6 years ago
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
6 years ago
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.
6 years ago
Igor Kulikov
3e2a87135f
Prepare for merge with master
6 years ago
Igor Kulikov
850d6d948c
Update License header year to 2020
7 years ago
Igor Kulikov
1265a9a1e3
Revert "Update License header year to 2020"
This reverts commit 9b42397c4a .
7 years ago
Igor Kulikov
9b42397c4a
Update License header year to 2020
7 years ago
Andrew Shvayka
f41cd97cbb
MessageId to PacketId refactoring
7 years ago
Andrew Shvayka
3b52f9817d
MessageId to PacketId refactoring
7 years ago
Igor Kulikov
ced63c4e70
Update License Header year to 2019
8 years ago
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
8 years ago
Andrew Shvayka
f5bd9a2133
Issue #1327 fixed
8 years ago
Igor Kulikov
b40a135a7e
Fix NPE in MqttClient
8 years ago
Chi Joung So
44a1fa2911
ReconnectDelay and MaxBytesInMessage configurable
8 years ago
Igor Kulikov
309598c2ac
subscribtion -> subscription typo fix.
8 years ago
Igor Kulikov
17adf8bd8b
Improved MQTT client and added default handler to handle reconnect subscriptions
8 years ago
Igor Kulikov
0ea799d8e3
Add Netty MQTT Client module.
8 years ago