diff options
Diffstat (limited to 'messagebus')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java index feec51643c4..99d9a6d6483 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java @@ -63,7 +63,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, private final AtomicBoolean destroyed = new AtomicBoolean(false); private final ProtocolRepository protocolRepository = new ProtocolRepository(); private final AtomicReference<Map<String, RoutingTable>> tablesRef = new AtomicReference<>(null); - private final CopyOnWriteHashMap<String, MessageHandler> sessions = new CopyOnWriteHashMap<>(); + private final Map<String, MessageHandler> sessions = new ConcurrentHashMap<>(); private final Network net; private final Messenger msn; private final Resender resender; @@ -72,7 +72,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, private int pendingCount = 0; private int pendingSize = 0; private final Thread careTaker = new Thread(this::sendBlockedMessages); - private final ConcurrentHashMap<SendBlockedMessages, Long> blockedSenders = new ConcurrentHashMap<>(); + private final Map<SendBlockedMessages, Long> blockedSenders = new ConcurrentHashMap<>(); public interface SendBlockedMessages { /** |