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

1858 Commits

Author SHA1 Message Date
Andrii Shvaika
daac250c2e Correct close and cleanup of the MQTT session context 2021-08-05 17:22:40 +03:00
ShvaykaD
60e15ece5a replaced protobuf-wrappers usage to optional keyword 2021-08-05 16:53:09 +03:00
Andrew Shvayka
c1d8aa1370
Merge pull request #5038 from volodymyr-babak/handle-null-values-in-proto 
Handle null values in proto
 2021-08-05 15:44:33 +03:00
Sergey Matvienko
1d7e0b9851 queue.kafka.max.request.size:1048576 default to tolerate inconsistent or outdated yml 2021-08-05 15:27:45 +03:00
Sergey Matvienko
a5ff95b0f4 Kafka producer added TB_KAFKA_MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION and TB_KAFKA_MAX_REQUEST_SIZE 2021-08-05 15:27:45 +03:00
Viacheslav Klimov
3505810280 Bulk import device credentials handling refactoring 2021-08-05 15:13:05 +03:00
YevhenBondarenko
373f2f9f0e added additionalInfo to the rpc 2021-08-05 15:12:00 +03:00
Volodymyr Babak
2558b2ecda Device credential value can be null 2021-08-05 15:11:08 +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
Volodymyr Babak
0ce509e8e6 Merge remote-tracking branch 'upstream/master' into handle-null-values-in-proto 2021-08-04 09:45:27 +03:00
Volodymyr Babak
5557406f07 Added alarm id for future needs 2021-08-04 09:45:16 +03:00
Viacheslav Klimov
33592ca072 Bulk import for devices, assets and edges 2021-08-03 16:00:47 +03:00
YevhenBondarenko
ee74bbed21 fixed race condition during unreq and updating lwm2m client 2021-08-03 14:23:27 +03:00
Volodymyr Babak
eced5a49fa Merge remote-tracking branch 'upstream/master' into handle-null-values-in-proto 2021-08-03 13:14:38 +03:00
nickAS21
4457b5a11a Lwm2m: fix bug Bootstrap + Tests NoSec - ok 2021-08-03 12:24:39 +03:00
YevhenBondarenko
309715641f fixed race condition during unreq 2021-08-02 18:41:53 +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
Sergey Matvienko
2a4a9187d1 kafka producer - call callback.onFailure in case of producer.send exception (like InterruptedException when buffer.memory and max.block.ms reached) 2021-08-02 17:42:45 +03:00
Volodymyr Babak
e05e681bd9 Properly hanlde null values in proto classes 2021-07-30 18:22:19 +03:00
Igor Kulikov
aa0d05bb44
Merge pull request #4957 from volodymyr-babak/edge-fix-concurrent-async-issue 
[3.3.0] Added lock on edge event save/read. Removed save async method
 2021-07-30 11:42:27 +03:00
YevhenBondarenko
9a1000a45d fixed registration looping 2021-07-30 11:04:25 +03:00
YevhenBondarenko
4cbbefdd26 fw update improvements 2021-07-29 16:36:22 +03:00
Andrii Shvaika
d731c1df08 Fix tests 2021-07-27 18:44:02 +03:00
Andrii Shvaika
f932a90b00 Improvements to Persistent RPC call delivery confirmation 2021-07-26 15:57:27 +03:00
YevhenBondarenko
0fbb347b27 persistent rpc improvements 2021-07-26 14:20:00 +03:00
YevhenBondarenko
9720dfac47 Fixed lwm2m fw/sw logs 2021-07-26 14:11:17 +03:00
Volodymyr Babak
bf4ae8fd16 Merge remote-tracking branch 'upstream/master' into edge-fix-concurrent-async-issue 2021-07-23 14:40:33 +03:00
Andrew Shvayka
1f6210197c
Merge pull request #4959 from YevhenBondarenko/feature/ota-tag 
[3.3.0] OtaPackage Tag
 2021-07-23 13:57:22 +03:00
YevhenBondarenko
c7274b6139 ota package tag improvements 2021-07-23 13:54:07 +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
60c9e43ea5 Uplink notifications for PSM & eDRX for CoAP in MSA deployment 2021-07-23 13:27:05 +03:00
YevhenBondarenko
52d07fe080 Merge branch 'feature/ota-tag' of github.com:YevhenBondarenko/thingsboard into feature/ota-tag 2021-07-22 18:48:46 +03:00
YevhenBondarenko
c9fbe74321 Used OtaPackage tag for FW/SW updates 2021-07-22 18:48:10 +03:00
Vladyslav_Prykhodko
5a88034645 UI: Add new fields tag in ota package component 2021-07-22 18:36:29 +03:00