X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fsal%2Fconnect%2Fnetconf%2FNotificationHandler.java;h=5e9b33efab4995754839085d27dc975bb7b2a2bf;hb=1aaec97aa24f5dfe62fd3e6523e651db883ab51f;hp=5b28366c07703d2b5337866f355438b5691bd4f2;hpb=6d7e12bf3ef64e5004703a1d540e7e26f30a9595;p=netconf.git diff --git a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/NotificationHandler.java b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/NotificationHandler.java index 5b28366c07..5e9b33efab 100644 --- a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/NotificationHandler.java +++ b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/NotificationHandler.java @@ -11,9 +11,9 @@ import com.google.common.base.Optional; import com.google.common.base.Preconditions; import java.util.LinkedList; import java.util.List; -import org.opendaylight.controller.config.util.xml.XmlUtil; import org.opendaylight.controller.md.sal.dom.api.DOMNotification; import org.opendaylight.netconf.api.NetconfMessage; +import org.opendaylight.netconf.api.xml.XmlUtil; import org.opendaylight.netconf.sal.connect.api.MessageTransformer; import org.opendaylight.netconf.sal.connect.api.RemoteDeviceHandler; import org.opendaylight.netconf.sal.connect.util.RemoteDeviceId; @@ -50,10 +50,10 @@ final class NotificationHandler { /** * Forward all cached notifications and pass all notifications from this point directly to sal facade. - * @param messageTransformer Message transformer + * @param transformer Message transformer */ - synchronized void onRemoteSchemaUp(final MessageTransformer messageTransformer) { - this.messageTransformer = Preconditions.checkNotNull(messageTransformer); + synchronized void onRemoteSchemaUp(final MessageTransformer transformer) { + this.messageTransformer = Preconditions.checkNotNull(transformer); passNotifications = true; @@ -72,7 +72,7 @@ final class NotificationHandler { } private void queueNotification(final NetconfMessage notification) { - Preconditions.checkState(passNotifications == false); + Preconditions.checkState(!passNotifications); LOG.debug("{}: Caching notification {}, remote schema not yet fully built", id, notification); if (LOG.isTraceEnabled()) { @@ -90,8 +90,8 @@ final class NotificationHandler { } } - synchronized void addNotificationFilter(final NotificationFilter filter) { - this.filter = filter; + synchronized void addNotificationFilter(final NotificationFilter newFilter) { + this.filter = newFilter; } synchronized void onRemoteSchemaDown() {