X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FForwardingDataTreeChangeListener.java;h=6cda0de15217c758ee1b04eb51da42b50a78b90d;hb=047566574ea74d1dfe24fa8075f8ba137faa698c;hp=12e4294916219fa824bb692f300ebf50568c2b63;hpb=925cb4a228d0fda99c7bfeb432eb25285a223887;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ForwardingDataTreeChangeListener.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ForwardingDataTreeChangeListener.java index 12e4294916..6cda0de152 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ForwardingDataTreeChangeListener.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ForwardingDataTreeChangeListener.java @@ -14,6 +14,8 @@ import java.util.Collection; import org.opendaylight.controller.cluster.datastore.messages.DataTreeChanged; import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener; import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * Internal implementation of a {@link DOMDataTreeChangeListener} which @@ -21,6 +23,8 @@ import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate; * message and forwards them towards the client's {@link DataTreeChangeListenerActor}. */ final class ForwardingDataTreeChangeListener implements DOMDataTreeChangeListener { + private static final Logger LOG = LoggerFactory.getLogger(ForwardingDataTreeChangeListener.class); + private final ActorSelection actor; ForwardingDataTreeChangeListener(final ActorSelection actor) { @@ -29,6 +33,12 @@ final class ForwardingDataTreeChangeListener implements DOMDataTreeChangeListene @Override public void onDataTreeChanged(Collection changes) { + LOG.debug("Sending DataTreeChanged to {}", actor); actor.tell(new DataTreeChanged(changes), ActorRef.noSender()); } + + @Override + public String toString() { + return "ForwardingDataTreeChangeListener [actor=" + actor + "]"; + } }