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%2FShardDataTreeChangeListenerPublisherActorProxy.java;h=020319203b0ccfccb423545534cfcae0ff61d1b1;hb=5e7cf2452ef634dc934a3ea5a2dd95059fbab68c;hp=ceaeeccaad8b700a9c262f25cdc7d1f50f590f60;hpb=ec870dee9bacb971f11bc747b69e84ac37f5d746;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeChangeListenerPublisherActorProxy.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeChangeListenerPublisherActorProxy.java index ceaeeccaad..020319203b 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeChangeListenerPublisherActorProxy.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataTreeChangeListenerPublisherActorProxy.java @@ -36,8 +36,10 @@ class ShardDataTreeChangeListenerPublisherActorProxy extends AbstractShardDataTr public void registerTreeChangeListener(YangInstanceIdentifier treeId, DOMDataTreeChangeListener listener, Optional currentState, Consumer> onRegistration) { - notifierActor().tell(new ShardDataTreeChangePublisherActor.RegisterListener(treeId, listener, currentState, - onRegistration), ActorRef.noSender()); + final ShardDataTreeChangePublisherActor.RegisterListener regMessage = + new ShardDataTreeChangePublisherActor.RegisterListener(treeId, listener, currentState, onRegistration); + log.debug("{}: Sending {} to publisher actor {}", logContext(), regMessage, publisherActor()); + publisherActor().tell(regMessage, ActorRef.noSender()); } @Override