fixed HashPartitionService

3 years ago · f3a0d3a7e8
1 changed files with 1 additions and 1 deletions
--- a/common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/discovery/HashPartitionService.java
@ -107,7 +107,7 @@ public class HashPartitionService implements PartitionService {

        QueueKey vcKey = new QueueKey(ServiceType.TB_VC_EXECUTOR);
        partitionSizesMap.put(vcKey, vcPartitions);
-        partitionTopicsMap.put(vcKey, topicService.buildTopicName(topicService.buildTopicName(vcTopic)));
+        partitionTopicsMap.put(vcKey, topicService.buildTopicName(vcTopic));

        if (!isTransport(serviceInfoProvider.getServiceType())) {
            doInitRuleEnginePartitions();