diff options
author | jonmv <venstad@gmail.com> | 2023-10-11 21:44:23 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-10-11 21:44:23 +0200 |
commit | ac6c7464aba758270e1aa2674ba8c0d25faed79d (patch) | |
tree | 93bd83dc9ef92b3d1cffd11e8926c24f2b686c24 /messagebus | |
parent | 57deef966539acdd3c96b52701fb29cf9062f6e0 (diff) |
Info log message when MbusServer is finally destroyed
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java | 3 | ||||
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/network/NetworkMultiplexer.java | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java b/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java index cbaeb25af58..7e8286d8793 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java @@ -119,6 +119,7 @@ public final class IntermediateSession implements MessageHandler, ReplyHandler, mbus.connect(name, broadcastName); } - @Override public void disconnect() { close(); } + @Override + public void disconnect() { close(); } } diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/NetworkMultiplexer.java b/messagebus/src/main/java/com/yahoo/messagebus/network/NetworkMultiplexer.java index 0759a5661be..85389c8b21f 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/NetworkMultiplexer.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/NetworkMultiplexer.java @@ -6,6 +6,7 @@ import com.yahoo.messagebus.Protocol; import com.yahoo.text.Utf8Array; import java.util.Deque; +import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedDeque; @@ -68,7 +69,7 @@ public class NetworkMultiplexer implements NetworkOwner { public void unregisterSession(String session, NetworkOwner owner, boolean broadcast) { sessions.computeIfPresent(session, (name, owners) -> { - if (owners.size() == 1 && owners.contains(owner)) { + if (owners.equals(List.of(owner))) { if (broadcast) net.unregisterSession(session); return null; |