From e0adc8da020f4a4670199a3f974f47c3140fdb75 Mon Sep 17 00:00:00 2001 From: Cody Cutrer Date: Sat, 21 Jan 2023 01:59:37 -0700 Subject: [PATCH] [mqtt] fix thread concurrency issue with type provider (#14229) Signed-off-by: Cody Cutrer --- .../binding/mqtt/generic/MqttChannelTypeProvider.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/bundles/org.openhab.binding.mqtt.generic/src/main/java/org/openhab/binding/mqtt/generic/MqttChannelTypeProvider.java b/bundles/org.openhab.binding.mqtt.generic/src/main/java/org/openhab/binding/mqtt/generic/MqttChannelTypeProvider.java index eb9296f580..7267c97186 100644 --- a/bundles/org.openhab.binding.mqtt.generic/src/main/java/org/openhab/binding/mqtt/generic/MqttChannelTypeProvider.java +++ b/bundles/org.openhab.binding.mqtt.generic/src/main/java/org/openhab/binding/mqtt/generic/MqttChannelTypeProvider.java @@ -14,10 +14,10 @@ package org.openhab.binding.mqtt.generic; 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 @@ import org.osgi.service.component.annotations.Reference; public class MqttChannelTypeProvider implements ThingTypeProvider, ChannelGroupTypeProvider, ChannelTypeProvider { private final ThingTypeRegistry typeRegistry; - private final Map types = new HashMap<>(); - private final Map groups = new HashMap<>(); - private final Map things = new HashMap<>(); + private final Map types = new ConcurrentHashMap<>(); + private final Map groups = new ConcurrentHashMap<>(); + private final Map things = new ConcurrentHashMap<>(); @Activate public MqttChannelTypeProvider(@Reference ThingTypeRegistry typeRegistry) { -- 2.47.3