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

239 Commits

Author SHA1 Message Date
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
ShvaykaD
a764838e62
Coap transport improvements (#4644) 
* added fix for PROD-518 in subscribe to attribute updates get request, added improvements

* updated coap observe requests implementation & updated tests

* updated coap attributes updates tests

* fix typos
 2021-05-28 14:19:40 +03:00
Andrii Shvaika
ceb26bbd61 Merge with master 2021-05-26 19:40:45 +03:00
Andrii Shvaika
25143378c2 Fix message order for Gateway and LwM2M transports in the core consumer 2021-05-26 18:24:22 +03:00
zbeacon
a4eb2df8ee Fix for device software/firmware response topic 2021-05-06 13:46:10 +03:00
zbeacon
4843baf7b9 Merge branch 'master' of https://github.com/thingsboard/thingsboard into feature/firmware-checksum-autogenerating 2021-04-30 14:43:10 +03:00
Andrii Shvaika
00bd26f1f5 Merge with master 2021-04-30 11:25:56 +03:00