X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=restconf%2Frestconf-nb-bierman02%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fsal%2Fstreams%2Flisteners%2FAbstractCommonSubscriber.java;h=2a7ba619c59a543fcedd6815912b458977396941;hb=fb750ca3247ee1cea29a7b97aa85c9da0fafb16e;hp=55ea16db73f3364fc73047cdff92b4c12d3006a7;hpb=7e47f4213d56d36fd83c0de1b1e317ee105a6048;p=netconf.git diff --git a/restconf/restconf-nb-bierman02/src/main/java/org/opendaylight/netconf/sal/streams/listeners/AbstractCommonSubscriber.java b/restconf/restconf-nb-bierman02/src/main/java/org/opendaylight/netconf/sal/streams/listeners/AbstractCommonSubscriber.java index 55ea16db73..2a7ba619c5 100644 --- a/restconf/restconf-nb-bierman02/src/main/java/org/opendaylight/netconf/sal/streams/listeners/AbstractCommonSubscriber.java +++ b/restconf/restconf-nb-bierman02/src/main/java/org/opendaylight/netconf/sal/streams/listeners/AbstractCommonSubscriber.java @@ -50,9 +50,12 @@ abstract class AbstractCommonSubscriber extends AbstractQueryParams implements B } @Override - public final void close() throws Exception { - this.registration.close(); - this.registration = null; + public final void close() { + if (registration != null) { + this.registration.close(); + this.registration = null; + } + unregister(); } @@ -65,7 +68,7 @@ abstract class AbstractCommonSubscriber extends AbstractQueryParams implements B */ public void addSubscriber(final Channel subscriber) { if (!subscriber.isActive()) { - LOG.debug("Channel is not active between websocket server and subscriber {}" + subscriber.remoteAddress()); + LOG.debug("Channel is not active between websocket server and subscriber {}", subscriber.remoteAddress()); } final Event event = new Event(EventType.REGISTER); event.setSubscriber(subscriber);