public/openhab-addons
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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

Browse Source 
Signed-off-by: Cody Cutrer <cody@cutrer.us>
This commit is contained in:
Cody Cutrer
2023-01-21 01:59:37 -07:00
committed by GitHub
parent dd790741a0
commit e0adc8da02
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
bundles/org.openhab.binding.mqtt.generic/src/main/java/org/openhab/binding/mqtt/generic/MqttChannelTypeProvider.java
View File

@@ -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<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) {