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

502 Commits

Author SHA1 Message Date
Igor Kulikov
7604b78f0e
Merge pull request #3405 from ShvaykaD/improvements/queue-reprocessing-strategy 
[2.5.5] Improvements/queue reprocessing strategy
 2020-09-16 12:08:44 +03:00
Dmytro Shvaika
ac2a0f5105 removed unnecessary flag 2020-09-04 16:13:29 +03:00
Dmytro Shvaika
f1b82c2d05 changed logic to multiplication pause 2020-09-03 17:04:52 +03:00
YevhenBondarenko
f16672cbf6 added partition property for kafka 2020-09-02 18:14:23 +03:00
Dmytro Shvaika
b93f3d18c0 added ability to use exp-pause-between-retries on queue msgs reprocessing 2020-09-01 16:13:42 +03:00
Igor Kulikov
03fbc46654
Merge pull request #3383 from YevhenBondarenko/queue/improvements 
in memory queue logs
 2020-09-01 14:42:35 +03:00
Andrii Shvaika
8ec23f22d4 Version set 2.5.5-SNAPSHOT 2020-08-28 19:02:31 +03:00
YevhenBondarenko
e5ad5e0b30 refactored 2020-08-28 17:36:57 +03:00
YevhenBondarenko
18ca330c9e in memory queue logs 2020-08-28 17:02:04 +03:00
YevhenBondarenko
17ee07e09a changed log time 2020-08-28 16:01:43 +03:00
YevhenBondarenko
3794086726 added logs for in memory queue 2020-08-28 15:24:31 +03:00
ShvaykaD
e33709d830
fix/getAttributesRequest & fix/hsql-inserts-with-json (#3376) 
* fix GetAttributeRequest & Hsql inserts

* added deleted keys to GetAttributeResponseMsg for gateway

* changed logic for handleGetAttributesRequest on deleted attributes

* removed unused classes and remove deleted keys in GetAttributeResponseMsg proto

* revert yml file

* removed getDeletedAttributeKeysCount method call in Coap transport
 2020-08-27 17:11:00 +03:00
Andrii Shvaika
b341030c8f Version set to 2.5.4-SNAPSHOT 2020-08-20 16:52:41 +03:00
Yevhen Bondarenko
e318b193bd
Develop/2.5.3 confluent cloud (#3259) 
* added other parameters for queue kafka

* Added support Confluent Cloud

* fix js executor kafka connection

* refactored
 2020-08-11 11:15:41 +03:00
nordmif
52bed17489 changed logging level to WARN 2020-08-05 15:00:29 +03:00
nordmif
e5a6ddb03b added logging of MQTT payload errors 2020-08-05 15:00:29 +03:00
nordmif
045c8e3aca added logging of MQTT payload errors 2020-08-05 15:00:29 +03:00
nordmif
b445473e3c added logging of MQTT payload errors 2020-08-05 15:00:29 +03:00
YevhenBondarenko
86102aea06 added other parameters for queue kafka 2020-08-05 14:53:36 +03:00
Dmytro Shvaika
a8fe8b9e10 fix typo in ConditionalOnExpression annotation 2020-08-05 14:52:18 +03:00
YevhenBondarenko
090c36999f refactored 2020-08-03 17:29:42 +03:00
YevhenBondarenko
cc79b02603 added default credentials provider chain for aws sqs consumer and producer 2020-08-03 17:29:42 +03:00
Jan Schumann
3d9f1cf1e3 enable default credential provider chain for aws sqs 2020-08-03 17:29:42 +03:00
Dima Landiak
fea2f8799e improvements 2020-08-03 10:16:22 +03:00
Dima Landiak
ac007bea24 device swap feature init 2020-08-03 10:16:22 +03:00
vzikratyi
5b4cfbb3d8 Merged with develop/2.5.3 2020-07-24 11:28:27 +03:00
vzikratyi
0ccf7f13d1 Moved 'stats' to separate module 2020-07-24 11:28:27 +03:00
vzikratyi
d98bbacd43 Added stats to TbSqlQueue and BufferedRateExecutor 2020-07-24 11:28:27 +03:00
vzikratyi
1700cf7707 Added producer stats to 'transport' services 2020-07-24 11:28:27 +03:00
YevhenBondarenko
a84160a153 created azure iot hub rule node 2020-07-24 11:23:06 +03:00
Andrii Shvaika
af1f6229bb Improved logging of failed and timeout messages 2020-07-14 10:34:20 +03:00
vzikratyi-tb
89419c6999
Prometheus Metrics (#3052) 
* Moved resetting ruleEngineStats to Consumer

* Moved counters to Map in TbCoreConsumerStats

* Added actuator and MetricsService

* Added metrics to core and rule_engine consumers

* Replaced summary with counters

* Removed most setters and getters from TbRuleEngine stats

* Added stats to Transport consumer

* Added JsInvoke actuator stats

* Removed MetricsService
 2020-07-06 14:47:36 +03:00
Dmytro Shvaika
7d739dfaae fix PsqlTsDao annotation & sql-ttl services 2020-07-03 14:08:33 +03:00
YevhenBondarenko
306674511c fix bug in DefaultTbQueueRequestTemplate when responses is empty tickTs did not update 2020-06-16 11:41:31 +03:00
Andrii Shvaika
9d2e039220 Version set to 2.5.3-SNAPSHOT 2020-06-11 10:57:50 +03:00
Andrii Shvaika
65c644b86f Message is pushed to correct queue in case of duplication 2020-06-08 18:01:26 +03:00
Andrii Shvaika
ab890e6b1c Improved handling of peak connect attempts 2020-06-08 13:41:49 +03:00
Andrii Shvaika
a6733c42c4 ThingsBoard Actor Init improvements 2020-06-08 10:58:22 +03:00
Andrii Shvaika
cc4f746b1d Using Exectutor in Kafka Node. NEVER use Fork-Join pool with parallelism 1 2020-06-05 12:54:27 +03:00
Andrii Shvaika
3358c061da Improvements to Mailbox. HighPriorityQueue 2020-06-05 10:26:50 +03:00
Andrii Shvaika
bb1585592b Actor System refactoring 2020-06-04 17:59:55 +03:00
Andrii Shvaika
0fbe40c2a6 TB Actor System initial commit 2020-06-03 19:33:49 +03:00
Andrii Shvaika
a532ded5ae Version set to 2.5.2-SNAPSHOT 2020-06-01 16:11:57 +03:00
Andrii Shvaika
37b9311be9 Empty partitions 2020-05-28 18:17:20 +03:00
Andrii Shvaika
2407c868c1 Cluster mode improvements 2020-05-28 17:40:26 +03:00
Andrii Shvaika
6f13f84f3a MVN warnings 2020-05-25 16:39:16 +03:00
Andrii Shvaika
670a218e6d Added ts to TbMsg 2020-05-25 15:28:55 +03:00
viktor
4ed334a5d5 Merge branch 'develop/2.5.1' into oauth2-default-dashboard 2020-05-21 10:26:32 +03:00
viktor
cac7eb0d2b Added 'alwaysFullScreen' and 'defaultDashboardName' oauth2 properties 2020-05-20 18:27:26 +03:00
Andrii Shvaika
676868b4d3 Fix for Transport API subscriptions 2020-05-20 15:37:06 +03:00