Andrii Landiak
b29cc4fc41
Fix tupo
1 year ago
Andrii Shvaika
62da129d6b
Review comments fixed
1 year ago
Igor Kulikov
5cf26d4851
Update license header
1 year ago
ViacheslavKlimov
ab9bef4d90
Fix HashPartitionServiceTest
1 year ago
ViacheslavKlimov
ed6ca38524
Fix locking in QueueStateService
2 years ago
Andrii Shvaika
535730b61a
Minor renaming due to code review
2 years ago
ViacheslavKlimov
2b3af16530
CF states restore improvements
2 years ago
ViacheslavKlimov
5dc6991907
Kafka states restore improvements
2 years ago
ViacheslavKlimov
ffc88eeb2d
CF Kafka states cleanup
2 years ago
ViacheslavKlimov
f342bd989e
Minor improvements
2 years ago
ViacheslavKlimov
677385e8ba
CF states restore from Kafka
2 years ago
Andrii Shvaika
d75bc3ac28
Minor improvements
2 years ago
Volodymyr Babak
1b4930ebaf
Introduced separate count for edge consumers
2 years ago
Volodymyr Babak
3860d79613
Improved Edge handling in case connect/disconnect. Speed up initial setup
2 years ago
Andrii Shvaika
5efb94dc7a
Refactoring
2 years ago
Andrii Landiak
b54e0cd59c
Rename tbEdgeEventNotificationsTopic
2 years ago
Andrii Landiak
8de861f897
Improve customization for edge-event topic
2 years ago
Andrii Shvaika
407511be52
Cache implementation
2 years ago
Andrii Landiak
e3a72fec09
Refactor TopicService. Change ymls to be able to configure notification topic names
2 years ago
Andrii Shvaika
d3278f05bb
WIP: Cluster mode refactoring
2 years ago
IrynaMatveieva
0e1cd69e34
updated cf consumer
2 years ago
IrynaMatveieva
5641626443
added processNotification impl
2 years ago
IrynaMatveieva
2cc0d6f513
added implementations for consumer/producer methods
2 years ago
Andrii Shvaika
4c71b9d5f6
WIP: Cluster mode implementation
2 years ago
Andrii Shvaika
069725a2b9
WIP Refactoring of the cluster mode
2 years ago
Andrii Shvaika
6b9d374a5f
Tmp commit for merge
2 years ago
ViacheslavKlimov
e4cc2b4f9f
Introduce TbMsgTransformer
2 years ago
Andrii Landiak
988dfce500
Refactor KafkaEdgeTopicsCleanUpService to properly clean up both deleted edges and expired topics
2 years ago
Andrii Landiak
63b53a4a45
Final improvement after review
2 years ago
Andrii Landiak
76bed44705
Minor improvement
2 years ago
Andrii Landiak
c388034d01
Delete EdgeGrpcSession interface: use abstract instead
2 years ago
Andrii Landiak
b981281205
Fix tests
2 years ago
Andrii Landiak
50a55d15a9
Add poll properties for edge-event kafka poll
2 years ago
Andrii Landiak
38eeada8ec
Implement clean up service to clear empty edge topics
2 years ago
ViacheslavKlimov
12ca1739d4
Remove all queue types except Kafka
2 years ago
Andrii Landiak
3ecbd3258e
Introduce kafka approach to work with edge-event instead of postgres
2 years ago
ViacheslavKlimov
2c0b7eb2b3
Deprecate all queue types except Kafka and in-memory
2 years ago
Dmytro Skarzhynets
bbe328d158
Implemented safe scheduled thread pool
2 years ago
YevhenBondarenko
f10f63bb8a
fixed concurrent modification in TopicService
2 years ago
ThingsBoard Bot
189778efb9
License header format
2 years ago
Dmytro Skarzhynets
39049eecd9
Remove redundant logging of thread name and scheduler name
2 years ago
Dmytro Skarzhynets
f6a1c14353
Fix last activity not being reported when activity reporting period ends
2 years ago
Andrii Landiak
5602807dbe
Introduce Edge queue to handle edge notification messages
2 years ago
Andrii Landiak
c6ee0bff19
Add edgeIdsCache to decrease number of calls to db for findRelatedEdgeByEntityId
2 years ago
ViacheslavKlimov
92cabebb04
Fix unrecognized Kafka config 'session.timeout.ms'
2 years ago
Andrii Landiak
5ca6ad03e3
CE: optimize java imports
2 years ago
ViacheslavKlimov
88af44870e
Check for queueName emptiness on partition resolve
2 years ago
Viacheslav Klimov
5809d014de
Queue option to duplicate msgs to all partitions ( #10815 )
* Queue config option to duplicate msgs to all partitions
* UI for queue config option to duplicate msgs to all partitions
* Fixes for msg duplication; add tests
* Introduce TbRuleEngineProducerService
* Use TbRuleEngineProducerService in TbClusterService
* Fix DefaultTbClusterServiceTest
* Add correlationId to TbMsg
* Refactor TbMsg
* Support msg duplication for all msg types
2 years ago
Sergey Matvienko
5e3ff6fe20
minor cleanup
2 years ago
ViacheslavKlimov
1a264dafa7
Fix TbKafkaSettingsTest
2 years ago