X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fbroker%2Fimpl%2FPingPongDataBroker.java;h=2ba59127652311fde9aafff04f446762010feb76;hb=8934f076977283543b7d65aeb7935a5ecefb74d0;hp=b5ec58d54add8151632b955b30fe76f42fde894e;hpb=919145b1bf7d68e436efa9b22c174965005a174a;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongDataBroker.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongDataBroker.java index b5ec58d54a..2ba5912765 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongDataBroker.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/PingPongDataBroker.java @@ -33,7 +33,7 @@ public final class PingPongDataBroker extends ForwardingDOMDataBroker implements * * @param delegate Backend broker, may not be null. */ - public PingPongDataBroker(final @Nonnull DOMDataBroker delegate) { + public PingPongDataBroker(@Nonnull final DOMDataBroker delegate) { this.delegate = Preconditions.checkNotNull(delegate); } @@ -49,15 +49,22 @@ public final class PingPongDataBroker extends ForwardingDOMDataBroker implements @Override public void close() { - // TODO Auto-generated method stub + // intentionally NOOP } @Override public ListenerRegistration registerDataTreeChangeListener(final DOMDataTreeIdentifier treeId, final L listener) { - if (delegate instanceof DOMDataTreeChangeService) { - return ((DOMDataTreeChangeService)delegate).registerDataTreeChangeListener(treeId, listener); + final DOMDataTreeChangeService treeService = + (DOMDataTreeChangeService) delegate.getSupportedExtensions().get(DOMDataTreeChangeService.class); + if (treeService != null) { + return treeService.registerDataTreeChangeListener(treeId, listener); } throw new UnsupportedOperationException("Delegate " + delegate + " does not support required functionality"); } + + @Override + public String toString() { + return "PingPongDataBroker backed by " + delegate; + } }