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 d8a409e704..8bd15a1ccf 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 @@ -21,8 +21,8 @@ import org.thingsboard.server.common.data.id.TenantId; import org.thingsboard.server.common.msg.queue.ServiceType; import org.thingsboard.server.common.msg.queue.TopicPartitionInfo; -import java.util.HashMap; -import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; @Service public class TopicService { @@ -30,9 +30,9 @@ public class TopicService { @Value("${queue.prefix:}") private String prefix; - private final Map tbCoreNotificationTopics = new HashMap<>(); - private final Map tbRuleEngineNotificationTopics = new HashMap<>(); - private final Map tbEdgeNotificationTopics = new HashMap<>(); + private final ConcurrentMap tbCoreNotificationTopics = new ConcurrentHashMap<>(); + private final ConcurrentMap tbRuleEngineNotificationTopics = new ConcurrentHashMap<>(); + private final ConcurrentMap tbEdgeNotificationTopics = new ConcurrentHashMap<>(); /** * Each Service should start a consumer for messages that target individual service instance based on serviceId.