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=877deda59f31cdb1363858a9b116412b55728c7b;hpb=df1a4dbb37e0fb187c6d50d3bab1f9d88b888928;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 877deda59f..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 @@ -51,8 +51,11 @@ abstract class AbstractCommonSubscriber extends AbstractQueryParams implements B @Override public final void close() { - this.registration.close(); - this.registration = null; + 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);