diff --git a/p2p/src/main/java/bisq/network/p2p/mailbox/IgnoredMailboxMap.java b/p2p/src/main/java/bisq/network/p2p/mailbox/IgnoredMailboxMap.java index 1441f24e62c..f3b6ca7f346 100644 --- a/p2p/src/main/java/bisq/network/p2p/mailbox/IgnoredMailboxMap.java +++ b/p2p/src/main/java/bisq/network/p2p/mailbox/IgnoredMailboxMap.java @@ -17,12 +17,10 @@ package bisq.network.p2p.mailbox; - import bisq.common.proto.persistable.PersistableEnvelope; -import bisq.common.util.CollectionUtils; -import java.util.HashMap; -import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import lombok.EqualsAndHashCode; import lombok.Getter; @@ -32,17 +30,17 @@ @EqualsAndHashCode public class IgnoredMailboxMap implements PersistableEnvelope { @Getter - private final Map dataMap; + private final ConcurrentMap dataMap; public IgnoredMailboxMap() { - this.dataMap = new HashMap<>(); + this.dataMap = new ConcurrentHashMap<>(); } /////////////////////////////////////////////////////////////////////////////////////////// // PROTO BUFFER /////////////////////////////////////////////////////////////////////////////////////////// - public IgnoredMailboxMap(Map ignored) { + private IgnoredMailboxMap(ConcurrentMap ignored) { this.dataMap = ignored; } @@ -54,11 +52,7 @@ public protobuf.PersistableEnvelope toProtoMessage() { } public static IgnoredMailboxMap fromProto(protobuf.IgnoredMailboxMap proto) { - return new IgnoredMailboxMap(CollectionUtils.isEmpty(proto.getDataMap()) ? new HashMap<>() : proto.getDataMap()); - } - - public void putAll(Map map) { - dataMap.putAll(map); + return new IgnoredMailboxMap(new ConcurrentHashMap<>(proto.getDataMap())); } public boolean containsKey(String uid) {