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