dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix HashPartitionServiceTest

Browse Source
This commit is contained in:
ViacheslavKlimov 2025-02-24 12:19:17 +02:00
parent 45a3730708
commit ab9bef4d90
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java
View File

@ -426,6 +426,9 @@ public class HashPartitionServiceTest {
topicService); topicService);
ReflectionTestUtils.setField(partitionService, "coreTopic", "tb.core"); ReflectionTestUtils.setField(partitionService, "coreTopic", "tb.core");
ReflectionTestUtils.setField(partitionService, "corePartitions", 10); ReflectionTestUtils.setField(partitionService, "corePartitions", 10);
ReflectionTestUtils.setField(partitionService, "cfEventTopic", "tb_cf_event");
ReflectionTestUtils.setField(partitionService, "cfStateTopic", "tb_cf_state");
ReflectionTestUtils.setField(partitionService, "cfPartitions", 10);
ReflectionTestUtils.setField(partitionService, "vcTopic", "tb.vc"); ReflectionTestUtils.setField(partitionService, "vcTopic", "tb.vc");
ReflectionTestUtils.setField(partitionService, "vcPartitions", 10); ReflectionTestUtils.setField(partitionService, "vcPartitions", 10);
ReflectionTestUtils.setField(partitionService, "hashFunctionName", hashFunctionName); ReflectionTestUtils.setField(partitionService, "hashFunctionName", hashFunctionName);

4
common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java
View File

@ -62,9 +62,9 @@ public class HashPartitionService implements PartitionService {
private String coreTopic; private String coreTopic;
@Value("${queue.core.partitions:10}") @Value("${queue.core.partitions:10}")
private Integer corePartitions; private Integer corePartitions;
@Value("${queue.calculated_fields.event_topic}") @Value("${queue.calculated_fields.event_topic:tb_cf_event}")
private String cfEventTopic; private String cfEventTopic;
@Value("${queue.calculated_fields.state_topic}") @Value("${queue.calculated_fields.state_topic:tb_cf_state}")
private String cfStateTopic; private String cfStateTopic;
@Value("${queue.calculated_fields.partitions:10}") @Value("${queue.calculated_fields.partitions:10}")
private Integer cfPartitions; private Integer cfPartitions;