dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
19,499 Commits 106 Branches 71 Tags
Commit Graph

459 Commits

Author SHA1 Message Date
ShvaykaD
ac12eaecd8 Merge branch 'master' of github.com:ShvaykaD/thingsboard into feature/json-payload-for-v1-topics-in-proto-profile 2021-10-27 11:52:37 +03:00
ShvaykaD
bb8f92b122 fixed log typos in MqttTransportHandler 2021-10-27 11:31:59 +03:00
Igor Kulikov
362ccf9f31 Unified transport SSL credentials 2021-10-26 19:40:38 +03:00
ShvaykaD
0f71d0d8fc fix typos 2021-10-26 17:31:05 +03:00
ShvaykaD
75c1185d18 update logic after review 2021-10-26 17:25:27 +03:00
ShvaykaD
5f6b1d1ab3 MQTT backward compatibility adaptor: init commit 2021-10-26 12:59:05 +03:00
ShvaykaD
845d8247dd
[3.3.2] MQTT short topics support (#4967) 
* added mqtt short topics support

* remove volatile keyword from topic types parameters

* added new tests for mqtt short topics

* fix compilation error after merge

* improvements/typo-fixes after pull request review
 2021-10-08 15:20:38 +03:00
Andrii Shvaika
5bb6403407 Bug Fix after MQTT Transport connection statistics 2021-09-30 15:10:01 +03:00
Andrii Shvaika
d40bc48898 Ability to log number of active MQTT connections 2021-09-30 14:43:01 +03:00
Andrii Shvaika
c52c9a16ed Shutdown of the MQTT Transport in case of OOM error. 2021-09-29 12:16:39 +03:00
Igor Kulikov
049627db97 Version set to 3.3.2-SNAPSHOT 2021-09-06 18:55:10 +03:00
Igor Kulikov
7b6e8248d3
Merge branch 'master' into dependency-management-transitive-ce-3-3-1 2021-09-01 15:02:27 +03:00
Igor Kulikov
02b8b8b873
Merge branch 'master' into dependency-upgrade-test-scope 2021-09-01 14:57:02 +03:00
Sergey Matvienko
aefb7e4bb3 added netty-tcnative-boringssl-static.version 2.0.41.Final along with netty-all to support SSL 2021-09-01 13:55:45 +03:00
Andrii Shvaika
e5b988a297 Merge branch 'rpc-improvements' of https://github.com/YevhenBondarenko/thingsboard into develop/3.3.1 2021-08-19 18:04:32 +03:00
YevhenBondarenko
2a2441b248 used timeout from yml 2021-08-18 16:46:01 +03:00
YevhenBondarenko
5d6ec0dd0e refactoring 2021-08-18 10:48:04 +03:00
YevhenBondarenko
8513c99903 added sequence for the all RPC 2021-08-18 09:56:57 +03:00
YevhenBondarenko
8869dc0cb0 added new RPC statuses 2021-08-17 13:25:24 +03:00
Andrii Shvaika
3661647c3a Version set to 3.3.1-SNAPSHOT 2021-08-16 12:39:43 +03:00
Andrii Shvaika
2078c71d32 Added module cluster-api and used it in rule engine and other services 2021-08-06 17:33:52 +03:00
Sergey Matvienko
e223dda96f test scope: dependency upgrade a refactor for all POMs in project 2021-08-06 13:53:35 +03:00
Andrii Shvaika
daac250c2e Correct close and cleanup of the MQTT session context 2021-08-05 17:22:40 +03:00
Andrii Shvaika
9d651a7252 Fix reference count issue 2021-08-05 15:10:04 +03:00
Sergey Matvienko
33887ecb3b mqtt handler test improved 2021-08-04 19:02:16 +03:00
Sergey Matvienko
69a7779253 added MqttTransportHandlerTest 2021-08-04 19:02:16 +03:00
Sergey Matvienko
cbe51cee57 execute processMsgQueue on connected callback in separate thread because producer.send() will execute in Producer worker thread and can block messages producing 2021-08-04 19:02:16 +03:00
Sergey Matvienko
607fd7a74f mqtt transport handler refactored for test 2021-08-04 19:02:16 +03:00
Sergey Matvienko
43fc44f071 fixed >= with > for MessageQueueSizePerDeviceLimit according to test results 2021-08-04 19:02:16 +03:00
Sergey Matvienko
7dfed3e14a removed msg-processor-on-device-connect executor. will use transportCallbackExecutor instead 2021-08-04 19:02:16 +03:00
Sergey Matvienko
efe123d96b transport.mqtt.msg_queue_size_per_device_limit:100 in code 2021-08-04 19:02:16 +03:00
Sergey Matvienko
1f1f7e3456 DeviceAwareSessionContext refactored: setDeviceInfo splitted into setDeviceInfo and setConnected to able to set connected status on callback after device info already set. 2021-08-04 19:02:16 +03:00
Sergey Matvienko
40bcd2fa8a mqtt transport refactored msqProcessorExecutor lifecycle 2021-08-04 19:02:16 +03:00
Sergey Matvienko
712ccd4c26 mqtt transport renamed thread pool msqProcessorExecutor 2021-08-04 19:02:16 +03:00
Sergey Matvienko
5741e34c62 mqtt transport accumulate msg before device isConnected 2021-08-04 19:02:16 +03:00
Sergey Matvienko
b8cecbeefd close channel if processPostTelemetryMsg exception (Failed to convert telemetry) 2021-08-02 17:45:22 +03:00
Sergey Matvienko
e3303f1b64 this.deviceCreationLockMap = createWeakMap(); 2021-08-02 17:45:22 +03:00
Sergey Matvienko
6e559994ca GatewaySessionHandlerTest license header fixed for CE 2021-08-02 17:45:22 +03:00
Sergey Matvienko
2cad1f9912 gateway session test added for a weak map with awaitility 2021-08-02 17:45:22 +03:00
Sergey Matvienko
89e3ba253c gateway session - weak map for locks (auto cleanup), getDeviceCreationFuture refactored using concurrent putIfAbsent 2021-08-02 17:45:22 +03:00
Sergey Matvienko
e61d433082 mqtt transport close channel on processing exception for handleGatewayPublishMsg method 2021-08-02 17:43:13 +03:00
Andrii Shvaika
f932a90b00 Improvements to Persistent RPC call delivery confirmation 2021-07-26 15:57:27 +03:00
Andrii Shvaika
99b19034e2 Uplink notifications for PSM & eDRX for CoAP in MSA deployment 2021-07-23 13:50:48 +03:00
Andrii Shvaika
a4636347e5 Merge PSM & eDRX for LwM2M 2021-07-22 11:45:08 +03:00
ShvaykaD
60ccd7a0b0 revert default behavior for no presense proto keys 2021-07-14 15:56:38 +03:00
ShvaykaD
a1336f3893 updated protobuf version to 3.17.2 & added explicit fields presence support 2021-07-14 15:56:38 +03:00
Andrii Shvaika
0c60e18ea6 Improved persistent RPC for unack requests 2021-07-14 14:23:54 +03:00
Andrii Shvaika
e914425b22 PR Review + minor logging 2021-07-14 13:32:34 +03:00
YevhenBondarenko
63342dfb7f saving persistent rpc if ack not expected 2021-07-14 08:58:50 +03:00
YevhenBondarenko
f473190502 check acknowledgement for persisted rpc 2021-07-13 13:38:33 +03:00