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

245 Commits

Author SHA1 Message Date
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
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
Igor Kulikov
a230e5838b Use single SSL context for mqtt transport 2021-06-30 20:32:50 +03:00
Igor Kulikov
b3dc441428 Fix io.netty.handler.ssl.SslHandler is not a @Sharable handler 2021-06-30 20:03:21 +03:00
Igor Kulikov
b2d694f7ee Add separate SSL channel for mqtt transport 2021-06-30 19:30:39 +03:00
Andrii Shvaika
9f499d9188 ResourceUtil implementation 2021-06-30 18:04:06 +03:00
ShvaykaD
d6bbeae335 fix for MqttSslHandlerProvider component injection & fix for skip_check_client_certificate parameter injection 2021-06-30 16:04:57 +03:00
YevhenBondarenko
b197965ab8 Merge branch 'master' of https://github.com/thingsboard/thingsboard into feature/power-mode 2021-06-24 12:05:29 +03:00
YevhenBondarenko
a665b2cbe6 added power mode to lwm2m-device-profile-transport-configuration 2021-06-24 10:53:35 +03:00
ShvaykaD
f135517237 merge with upstream/master 2021-06-22 20:48:36 +03:00
ShvaykaD
d3e16ad650 updated observe sessions closing actions 2021-06-22 13:31:08 +03:00
YevhenBondarenko
5626c30f2f Merge branch 'master' of https://github.com/thingsboard/thingsboard into feature/persisted-rpc 
# Conflicts:
#	common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/DefaultLwM2MTransportMsgHandler.java
 2021-06-11 11:27:28 +03:00
YevhenBondarenko
489c67778a implemented persisted RPC 2021-06-11 11:10:06 +03:00
nickAS21
f0f08fd0c9 LWM2M: fix bug RPC device of line 2021-06-03 08:21:23 +03:00
YevhenBondarenko
139af45fd3 Renamed Firmware to OtaPackage 2021-06-02 12:24:24 +03:00
YevhenBondarenko
a7239c9d39 Renamed Firmware to OtaPackage 2021-05-31 16:43:33 +03:00