diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-08-17 15:29:58 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-08-17 15:29:58 +0200 |
commit | 2c359931f393859a590a0a707ff69f50f70fede7 (patch) | |
tree | 7ad517c697471422b73ce6f517a258629e4cc20b /container-messagebus/src/main/java/com/yahoo | |
parent | c31ef822e361eddb82f17a1cdd6baa0fa0677ad4 (diff) |
Unregister sessions on server close
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo')
3 files changed, 18 insertions, 5 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/ServerSession.java b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/ServerSession.java index 56713815c7a..4cd4a776292 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/ServerSession.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/ServerSession.java @@ -10,13 +10,16 @@ import com.yahoo.messagebus.Reply; */ public interface ServerSession extends SharedResource { - public MessageHandler getMessageHandler(); + MessageHandler getMessageHandler(); - public void setMessageHandler(MessageHandler msgHandler); + void setMessageHandler(MessageHandler msgHandler); - public void sendReply(Reply reply); + void sendReply(Reply reply); - public String connectionSpec(); + String connectionSpec(); + + String name(); + + void close(); - public String name(); } diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java index 7da164757cd..5a9cd39c5b4 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java @@ -77,6 +77,11 @@ public class SharedDestinationSession extends AbstractResource implements Messag } @Override + public void close() { + session.destroy(); + } + + @Override protected void destroy() { log.log(Level.FINE, "Destroying shared destination session."); session.destroy(); diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java index 5c9fab46e34..64cc1aaf510 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java @@ -96,6 +96,11 @@ public class SharedIntermediateSession extends AbstractResource } @Override + public void close() { + session.destroy(); + } + + @Override protected void destroy() { log.log(Level.FINE, "Destroying shared intermediate session."); session.destroy(); |