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 /container-messagebus | |
| parent | 4c676c8e75393a4095307f269381158858b20e43 (diff) | |
Add disconnect() that unregisters session
Diffstat (limited to 'container-messagebus')
3 files changed, 9 insertions, 2 deletions
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 e0ab9dbff4f..49057330774 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 @@ -3,7 +3,6 @@ package com.yahoo.messagebus.shared; import com.yahoo.jdisc.AbstractResource; import com.yahoo.jdisc.ResourceReference; -import java.util.logging.Level; import com.yahoo.messagebus.DestinationSession; import com.yahoo.messagebus.DestinationSessionParams; import com.yahoo.messagebus.EmptyReply; @@ -14,6 +13,7 @@ import com.yahoo.messagebus.MessageHandler; import com.yahoo.messagebus.Reply; import java.util.concurrent.atomic.AtomicReference; +import java.util.logging.Level; import java.util.logging.Logger; /** @@ -81,6 +81,8 @@ public class SharedDestinationSession extends AbstractResource implements Messag session.connect(); } + @Override public void disconnect() { session.disconnect(); } + @Override protected void destroy() { log.log(Level.FINE, "Destroying shared destination session."); 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 06c6192cb7a..49bf6ba8fb7 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 @@ -3,7 +3,6 @@ package com.yahoo.messagebus.shared; import com.yahoo.jdisc.AbstractResource; import com.yahoo.jdisc.ResourceReference; -import java.util.logging.Level; import com.yahoo.messagebus.EmptyReply; import com.yahoo.messagebus.Error; import com.yahoo.messagebus.ErrorCode; @@ -16,6 +15,7 @@ import com.yahoo.messagebus.ReplyHandler; import com.yahoo.messagebus.Result; import java.util.concurrent.atomic.AtomicReference; +import java.util.logging.Level; import java.util.logging.Logger; /** @@ -101,6 +101,9 @@ public class SharedIntermediateSession extends AbstractResource } @Override + public void disconnect() { session.disconnect(); } + + @Override protected void destroy() { log.log(Level.FINE, "Destroying shared intermediate session."); session.destroy(); diff --git a/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerTestCase.java b/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerTestCase.java index 84a722a753f..d8481138a99 100644 --- a/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerTestCase.java +++ b/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/MbusServerTestCase.java @@ -354,6 +354,8 @@ public class MbusServerTestCase { @Override public void connect() { } + @Override public void disconnect() {} + @Override public ResourceReference refer() { ++refCount; |