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

352 Commits

Author SHA1 Message Date
Dima Landiak
0745ee3d0a fixed passed topic name for consumer constructor in rule engine queue 2021-10-27 11:26:46 +03:00
Igor Kulikov
e2f2605197 Fix fork join pool - use current classloader for thread context classloader instead of system 2021-10-22 09:53:25 +03:00
Sergey Matvienko
d98419106b InMemoryStorage: added getLagTotal to be able to await while queue have any messages (no guarantee that messages was processed). 2021-10-18 16:47:43 +03:00
Igor Kulikov
b173e0799c Update OS package plugin version. Code cleanup. 2021-09-07 11:47:43 +03:00
Sergey Matvienko
8601121e7e executors: named fixed thread pools; tests - added executor shutdown on tearDown 2021-09-01 14:08:03 +03:00
Andrii Shvaika
37fd7f4988 Validation and Replacement of Queue names in the Device profile 2021-08-26 15:51:59 +03:00
Andrii Shvaika
8a2dc7583b Fix cluster mode for DefaultOtaPackageStateService 2021-08-09 14:33:41 +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
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
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
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
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
Andrii Shvaika
3a7a97dd91 PSM and eDRX implementation draft 2021-07-22 11:45:08 +03:00
Sergey Matvienko
395935fcad toString added for tbApplicationEvent and PartitionChangeEvent to provide a better log experience 
# Conflicts:
#	common/queue/src/main/java/org/thingsboard/server/queue/discovery/PartitionChangeEvent.java
#	common/queue/src/main/java/org/thingsboard/server/queue/discovery/TbApplicationEvent.java
 2021-07-14 12:35:42 +03:00
YevhenBondarenko
040473ac80 added edrxCycle to the Lwm2mDeviceTransportConfiguration 2021-07-12 12:26:51 +03:00
Sergey Matvienko
369844295f rule-engine: consumer per partition feature 2021-06-27 02:51:21 +03:00
YevhenBondarenko
a665b2cbe6 added power mode to lwm2m-device-profile-transport-configuration 2021-06-24 10:53:35 +03:00
YevhenBondarenko
daca44dbd8 revert TransportToDeviceActorMsg and added SendPendingRPCMsg to the end of the list. 2021-06-22 18:08:02 +03:00
YevhenBondarenko
a44bc1ba93 added SendPendingRPC transport msg 2021-06-22 16:21:56 +03:00
YevhenBondarenko
f1f41851cc merge with master 2021-06-22 15:46:39 +03:00
Igor Kulikov
461881b329
Merge pull request #4753 from smatvienko-tb/DefaultTbQueueRequestTemplateTest-refactor-and-test 
Default tb queue request template refactor and test, improved log experience for easy debug. TbStopWatch util class added
 2021-06-18 17:36:15 +03:00
Sergey Matvienko
bec228bc83 test: removed unnecessary stubbing on DefaultTbQueueRequestTemplateTest 2021-06-17 13:42:37 +03:00
Sergey Matvienko
aaedb9e879 DefaultTbQueueRequestTemplateTest updated licence header for CE 2021-06-17 13:35:20 +03:00
Sergey Matvienko
63c906250c log cleanup DefaultTbQueueRequestTemplate 2021-06-17 13:27:52 +03:00
Sergey Matvienko
ed44ac8f19 test fixed for DefaultTbQueueRequestTemplateTest 2021-06-17 13:27:19 +03:00
Sergey Matvienko
7e551cc92a log: reduced severity to trace for DefaultTbQueueRequestTemplate.setupNextCleanup() 2021-06-17 13:11:50 +03:00
Sergey Matvienko
3c72d0d608 log WARN for onScriptExecutionError to prevent silent ban (actually, system going to idle if the script is a part of a rule chain). restored TRACE level on fetchAndProcessResponses 2021-06-17 13:03:49 +03:00
Sergey Matvienko
9daa43a115 queue request template: sleep on exception shortened according to the stopwatch. test adjusted 2021-06-17 13:02:15 +03:00
Sergey Matvienko
16a55b16e4 js invoke service: logs added when script going to disable due to exception (special log for TimeoutException) 2021-06-17 13:01:13 +03:00
Sergey Matvienko
053d1d8e41 kafka commit sync 2021-06-17 12:57:31 +03:00
Sergey Matvienko
eee2d83ed5 sleep(poolInterval) replaced with parkNanos(1) for DefaultTbQueueRequestTemplate 2021-06-17 12:48:01 +03:00
Sergey Matvienko
1e066f2156 added timeout parameter to the TbQueueRequestTemplate.send( ) 2021-06-17 11:51:26 +03:00
Sergey Matvienko
928b8f0fd9 test: refactored for assertThat for DefaultTbQueueRequestTemplateTest 2021-06-17 11:50:00 +03:00
Sergey Matvienko
28235732c6 test: fixed class DefaultTbQueueRequestTemplate 2021-06-17 11:49:45 +03:00
Sergey Matvienko
9666986156 test: added failed test for FetchAndProcessResponses when request removed as staled too early DefaultTbQueueRequestTemplate 2021-06-17 11:49:33 +03:00
Sergey Matvienko
d5fffa5002 test: added failed test case with overflow maxPendingRequests for DefaultTbQueueRequestTemplate.send(). another refactoring for easy mocking. 2021-06-17 11:44:24 +03:00
Sergey Matvienko
872717828c test: refactored and added mainLoop test DefaultTbQueueRequestTemplate 2021-06-17 11:41:47 +03:00
Sergey Matvienko
9ed948933e test: added init stop test for DefaultTbQueueRequestTemplate 2021-06-17 11:41:35 +03:00
Sergey Matvienko
69fbc009c4 refactored for tests DefaultTbQueueRequestTemplate class 2021-06-17 11:40:58 +03:00
Sergey Matvienko
67c9025a06 improved logs for timeouts for DefaultTbQueueRequestTemplate 2021-06-17 11:22:35 +03:00
Sergey Matvienko
a04eac6015 added logs and timing metrics for DefaultTbQueueRequestTemplate, TbKafkaConsumerTemplate (todo revert or refactor) 2021-06-17 11:22:23 +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