diff options
| author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2022-01-25 10:46:09 +0100 |
|---|---|---|
| committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2022-01-25 10:49:53 +0100 |
| commit | 0c5400db597795c47ac054bb73fe268838383026 (patch) | |
| tree | 109706b721c5aa73b047ed42c54619d0c96cba06 /messagebus/src/main | |
| parent | 4c676c8e75393a4095307f269381158858b20e43 (diff) | |
Add disconnect() that unregisters session
Diffstat (limited to 'messagebus/src/main')
3 files changed, 5 insertions, 0 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Connectable.java b/messagebus/src/main/java/com/yahoo/messagebus/Connectable.java index db8d926db43..354548a3cf3 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/Connectable.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Connectable.java @@ -9,5 +9,6 @@ package com.yahoo.messagebus; public interface Connectable { void connect(); + void disconnect(); } diff --git a/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java b/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java index 509ea5903c5..10d1a93031d 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/DestinationSession.java @@ -130,4 +130,6 @@ public final class DestinationSession implements Connectable, MessageHandler { mbus.connect(name, broadcastName); } + @Override public void disconnect() { mbus.unregisterSession(name, broadcastName);; } + } diff --git a/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java b/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java index d5b7e045254..1473f40ef0a 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/IntermediateSession.java @@ -119,4 +119,6 @@ public final class IntermediateSession implements MessageHandler, ReplyHandler, mbus.connect(name, broadcastName); } + @Override public void disconnect() { mbus.unregisterSession(name, broadcastName); } + } |