[mqtt] fix thread concurrency issue with type provider (openhab#14229)

Signed-off-by: Cody Cutrer <cody@cutrer.us>
renescherer · Mar 23, 2023 · 0bd72cd · 0bd72cd
1 parent a34b90f
commit 0bd72cd
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/....mqtt.generic/src/main/java/org/openhab/binding/mqtt/generic/MqttChannelTypeProvider.java b/....mqtt.generic/src/main/java/org/openhab/binding/mqtt/generic/MqttChannelTypeProvider.java
@@ -14,10 +14,10 @@
 
 import java.net.URI;
 import java.util.Collection;
-import java.util.HashMap;
 import java.util.Locale;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
 
 import org.eclipse.jdt.annotation.NonNullByDefault;
 import org.eclipse.jdt.annotation.Nullable;
@@ -53,9 +53,9 @@
 public class MqttChannelTypeProvider implements ThingTypeProvider, ChannelGroupTypeProvider, ChannelTypeProvider {
     private final ThingTypeRegistry typeRegistry;
 
-    private final Map<ChannelTypeUID, ChannelType> types = new HashMap<>();
-    private final Map<ChannelGroupTypeUID, ChannelGroupType> groups = new HashMap<>();
-    private final Map<ThingTypeUID, ThingType> things = new HashMap<>();
+    private final Map<ChannelTypeUID, ChannelType> types = new ConcurrentHashMap<>();
+    private final Map<ChannelGroupTypeUID, ChannelGroupType> groups = new ConcurrentHashMap<>();
+    private final Map<ThingTypeUID, ThingType> things = new ConcurrentHashMap<>();
 
     @Activate
     public MqttChannelTypeProvider(@Reference ThingTypeRegistry typeRegistry) {