From dd5319337140209808dd6c5e788e39b5d2d672a9 Mon Sep 17 00:00:00 2001
From: dashevchenko <dshevchenko@thingsboard.io>
Date: Wed, 18 Oct 2023 11:43:21 +0300
Subject: [PATCH] fixed unit tests

---
 .../server/queue/discovery/HashPartitionServiceTest.java        | 2 ++
 .../org/thingsboard/server/queue/discovery/TopicService.java    | 2 --
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java b/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java
index 511faa6a2b..44c21a54d2 100644
--- a/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java
+++ b/application/src/test/java/org/thingsboard/server/queue/discovery/HashPartitionServiceTest.java
@@ -62,6 +62,7 @@ import static org.mockito.ArgumentMatchers.argThat;
 import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.spy;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
@@ -88,6 +89,7 @@ public class HashPartitionServiceTest {
         routingInfoService = mock(TenantRoutingInfoService.class);
         queueRoutingInfoService = mock(QueueRoutingInfoService.class);
         topicService = mock(TopicService.class);
+        when(topicService.buildTopicName(Mockito.any())).thenAnswer(i -> i.getArguments()[0]);
         clusterRoutingService = createPartitionService();
         ServiceInfo currentServer = ServiceInfo.newBuilder()
                 .setServiceId("tb-core-0")
diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/discovery/TopicService.java b/common/queue/src/main/java/org/thingsboard/server/queue/discovery/TopicService.java
index 27023f1619..bab0afbb23 100644
--- a/common/queue/src/main/java/org/thingsboard/server/queue/discovery/TopicService.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/discovery/TopicService.java
@@ -15,7 +15,6 @@
  */
 package org.thingsboard.server.queue.discovery;
 
-import lombok.Getter;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.thingsboard.server.common.data.id.TenantId;
@@ -28,7 +27,6 @@ import java.util.Map;
 @Service
 public class TopicService {
 
-    @Getter
     @Value("${queue.prefix}")
     private String prefix;