diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2022-01-25 10:57:41 +0100 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2022-01-25 10:57:41 +0100 |
commit | 0c2040f55e1d2360f923a827b5c0044f7fab97ee (patch) | |
tree | 8cbe9c34d0e448f8513045b72bb05c46549fb007 /messagebus | |
parent | 5ef47dd52687b3c6185989cfc465f46edf557e29 (diff) |
Sync with messagebus thread when disconnecting
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java | 2 | ||||
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java b/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java index 10d1a93031d..32f7ccd2e18 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java @@ -130,6 +130,6 @@ public final class DestinationSession implements Connectable, MessageHandler { mbus.connect(name, broadcastName); } - @Override public void disconnect() { mbus.unregisterSession(name, broadcastName);; } + @Override public void disconnect() { close(); } } diff --git a/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java b/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java index 1473f40ef0a..cbc5d89be79 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java @@ -119,6 +119,6 @@ public final class IntermediateSession implements MessageHandler, ReplyHandler, mbus.connect(name, broadcastName); } - @Override public void disconnect() { mbus.unregisterSession(name, broadcastName); } + @Override public void disconnect() { close(); } } |