X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fbroker%2Fimpl%2Fcompat%2FTranslatingListenerInvoker.java;h=7bcd02ed68a0c4ee491071c5f9cc3cba3b72c8ea;hp=1ce252df98ca4e030ec4fdfc43dd5004a432d54a;hb=fda226a0b46de4b481829d5f627b90fe4df41314;hpb=19ec3dcf73b675ff204bb222ca909447ebcd3d21 diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingListenerInvoker.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingListenerInvoker.java index 1ce252df98..7bcd02ed68 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingListenerInvoker.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingListenerInvoker.java @@ -18,9 +18,10 @@ import org.opendaylight.controller.sal.core.api.data.DataChangeListener; import org.opendaylight.yangtools.concepts.Delegator; import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.data.api.CompositeNode; -import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; +@Deprecated abstract class TranslatingListenerInvoker implements AutoCloseable, DOMDataChangeListener, Delegator { private final DataChangeListener delegate; @@ -41,19 +42,19 @@ abstract class TranslatingListenerInvoker implements AutoCloseable, DOMDataChang } @Override - public void onDataChanged(final AsyncDataChangeEvent> normalizedChange) { + public void onDataChanged(final AsyncDataChangeEvent> normalizedChange) { delegate.onDataChanged(getLegacyEvent(normalizer, normalizedChange)); } - abstract DataChangeEvent getLegacyEvent(final DataNormalizer normalizer, - final AsyncDataChangeEvent> normalizedChange); + abstract DataChangeEvent getLegacyEvent(final DataNormalizer normalizer, + final AsyncDataChangeEvent> normalizedChange); @Override public DataChangeListener getDelegate() { return delegate; } - abstract void register(final DOMDataBroker backingBroker, final InstanceIdentifier normalizedPath); + abstract void register(final DOMDataBroker backingBroker, final YangInstanceIdentifier normalizedPath); @Override public void close() { @@ -62,18 +63,24 @@ abstract class TranslatingListenerInvoker implements AutoCloseable, DOMDataChang } } + @Override + public String toString() { + return getDelegate().getClass().getName(); + } + static final class TranslatingConfigListenerInvoker extends TranslatingListenerInvoker { public TranslatingConfigListenerInvoker(final DataChangeListener listener, final DataNormalizer normalizer) { super(listener, normalizer); } - DataChangeEvent getLegacyEvent(final DataNormalizer normalizer, final AsyncDataChangeEvent> normalizedChange) { + @Override + DataChangeEvent getLegacyEvent(final DataNormalizer normalizer, final AsyncDataChangeEvent> normalizedChange) { return TranslatingDataChangeEvent.createConfiguration(normalizedChange, normalizer); } @Override - void register(final DOMDataBroker backingBroker, final InstanceIdentifier normalizedPath) { + void register(final DOMDataBroker backingBroker, final YangInstanceIdentifier normalizedPath) { reg = backingBroker.registerDataChangeListener(LogicalDatastoreType.CONFIGURATION, normalizedPath, this, AsyncDataBroker.DataChangeScope.SUBTREE); } @@ -85,12 +92,13 @@ abstract class TranslatingListenerInvoker implements AutoCloseable, DOMDataChang super(listener, normalizer); } - DataChangeEvent getLegacyEvent(final DataNormalizer normalizer, final AsyncDataChangeEvent> normalizedChange) { + @Override + DataChangeEvent getLegacyEvent(final DataNormalizer normalizer, final AsyncDataChangeEvent> normalizedChange) { return TranslatingDataChangeEvent.createOperational(normalizedChange, normalizer); } @Override - void register(final DOMDataBroker backingBroker, final InstanceIdentifier normalizedPath) { + void register(final DOMDataBroker backingBroker, final YangInstanceIdentifier normalizedPath) { reg = backingBroker.registerDataChangeListener(LogicalDatastoreType.OPERATIONAL, normalizedPath, this, AsyncDataBroker.DataChangeScope.SUBTREE); }