YevhenBondarenko
d2961e39e7
merge with master
2024-02-06 22:40:27 +01:00
Dmytro Skarzhynets
f5a7fe73ab
Merge branch 'master' into feature/device-state-node
2024-02-06 14:11:57 +02:00
ViacheslavKlimov
1f50a8c3ad
Merge branch 'hotfix/3.6.2' into fix/actors-init
...
# Conflicts:
# common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java
2024-01-31 13:39:43 +02:00
dashevchenko
8c41935c70
merged with master
2024-01-31 13:27:32 +02:00
Andrew Shvayka
34fa9fe035
Merge pull request #10102 from thingsboard/hotfix/3.6.2
...
Hotfix/3.6.2 sync up
2024-01-31 13:15:34 +02:00
dashevchenko
ce9351ba27
deleted unused classes
2024-01-30 18:20:23 +02:00
ViacheslavKlimov
5875a40118
Error handling for PartitionChangeEvent listeners
2024-01-30 15:16:53 +02:00
ViacheslavKlimov
2f73512005
Don't remove from myPartitions on queue update
2024-01-25 15:47:26 +02:00
ViacheslavKlimov
27f448a543
Improve partition service logs
2024-01-25 12:04:18 +02:00
ViacheslavKlimov
a571153b7c
Single update message for multiple queues
2024-01-24 18:08:01 +02:00
Dmytro Skarzhynets
5e846116a8
Use consumer instead of runnable in SimpleTbQueueCallback
2024-01-24 17:27:10 +02:00
Dmytro Skarzhynets
c9d97553b8
Update license headers with 2024 year.
2024-01-24 11:10:17 +02:00
Dmytro Skarzhynets
085187176a
Merge branch 'master' into feature/device-state-node
2024-01-24 11:03:53 +02:00
Andrii Shvaika
74a2c58fa4
Merge the hotfixes
2024-01-17 16:04:14 +02:00
YevhenBondarenko
60be820915
merge with master
2024-01-15 18:51:00 +01:00
ViacheslavKlimov
8e126e57dc
Refactoring and fixes for partitions recalculation
2024-01-12 13:46:19 +02:00
YevhenBondarenko
720afebeeb
Used Java serialization for NotificationRuleTrigger
2024-01-09 12:31:23 +01:00
Igor Kulikov
c5a72ed8df
Update license header to 2024 year.
2024-01-09 10:46:16 +02:00
dashevchenko
5e471364de
changed fixedPool to newWorkStealingPool
2024-01-02 13:58:16 +02:00
YevhenBondarenko
61602330ec
merge with 3.7
2023-12-28 12:16:14 +01:00
dashevchenko
b95adb439a
added yml parameters for aws-sqs eproducer executor thread pool size
2023-12-27 17:06:26 +02:00
dashevchenko
f2ea1b87d7
added shutdown for producerExecutor
2023-12-27 14:51:20 +02:00
dashevchenko
63a85161b2
moved producer executor to TbAwsSqsAdmin
2023-12-27 14:44:49 +02:00
dashevchenko
3ac0cc241a
TbAwsSqsProducerTemplate: native thread allocation error fix (provided one executor for message sending with limited thread pool size)
2023-12-27 13:47:52 +02:00
YevhenBondarenko
1fc704bae1
test fixes and minor refactoring
2023-12-26 11:08:06 +01:00
YevhenBondarenko
feb44656f1
merge with master
2023-12-26 00:58:31 +01:00
YevhenBondarenko
8ccd70fc65
Used ProtoUtils instead of ProtoWIthFSTService for serialization
2023-12-20 17:33:04 +01:00
Andrew Shvayka
2283431702
Merge pull request #9619 from dashevchenko/pubsub
...
Pubsub executor thread pool size fix
2023-12-01 16:58:06 +02:00
YevhenBondarenko
8ac80476ad
added encode/decode time stats and refactoring
2023-11-27 23:13:03 +01:00
YevhenBondarenko
d6b56177a2
fst stats in Grafana
2023-11-21 16:00:30 +01:00
dashevchenko
fa12ba544d
moved pubsub queue executor to PubSubSettings
2023-11-20 15:20:40 +02:00
dashevchenko
66b768a499
added @Lazy to PubSubRuleNodeExecutorProvider
2023-11-17 14:45:38 +02:00
dashevchenko
fbec7aab25
moved pubsub executors to pubsubSettings
2023-11-17 12:18:03 +02:00
dashevchenko
1be39aa9aa
fixed license, env name refactoring
2023-11-16 16:16:38 +02:00
dashevchenko
08727b4c36
added executor provider for pubsub queue, added env variable to manage pubsub queue executor provider thread pool
2023-11-15 14:51:58 +02:00
dashevchenko
4f22ef9733
created PubSubExecutor to use each time publisher is created and do not produce too much threads created
2023-11-14 17:36:51 +02:00
Andrii Shvaika
d2cda21d25
Merge hotfix branch
2023-11-01 10:24:37 +02:00
dashevchenko
86f8965eab
fixed thingsboard.yml
2023-10-30 12:21:30 +02:00
dashevchenko
62703d3583
merged with upstream
2023-10-30 12:19:24 +02:00
ViacheslavKlimov
0812149524
Minor refactoring for HashPartitionService
2023-10-27 16:38:44 +03:00
ViacheslavKlimov
9e408cd6f3
Distribute partitions between Rule Engines based only on tenant id
2023-10-27 14:43:12 +03:00
Andrii Shvaika
d78bb26a73
Merge with hotfix/3.6
2023-10-26 17:11:29 +03:00
Andrii Shvaika
694b6bf851
Refactoring: new data structures and message flow
...
Local Subscription Service refactoring
Refactoring of the proto structures
Bug fixing after refactoring
Minor improvements and bug fixes
Improvements to avoid additional DB calls
Bug fixes after refactoring
Cluster mode improvements
2023-10-26 17:07:16 +03:00
dashevchenko
15e6190a9d
optimized topicName creation in HashPartitionService
2023-10-23 17:40:39 +03:00
dashevchenko
603be29f1b
fixed topic naming
2023-10-23 12:35:38 +03:00
dashevchenko
f3a0d3a7e8
fixed HashPartitionService
2023-10-23 11:54:45 +03:00
ViacheslavKlimov
be7854fb5b
Add 'isolated' to topic and consumer group name for isolated queues
2023-10-19 18:58:41 +03:00
ViacheslavKlimov
cf951ee2b2
Multiple improvements for Rule Engine consumer services
2023-10-19 11:09:34 +03:00
Andrii Shvaika
45fd970898
Refactoring in progress
2023-10-19 11:09:11 +03:00
dashevchenko
dd53193371
fixed unit tests
2023-10-18 11:43:21 +03:00