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%2FShardDataChangePublisherActor.java;h=ef40480e4d86fbf7fd15d70e613fedaaaaff3ee6;hb=4447f81c26b851e46acd3f111768bb498f0d553f;hp=cb7d80dbdc199b36ab031ec32f08134dfd3c0901;hpb=1af0eab4206943f36fef2f6045b9fe73eafff594;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataChangePublisherActor.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataChangePublisherActor.java index cb7d80dbdc..ef40480e4d 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataChangePublisherActor.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardDataChangePublisherActor.java @@ -27,7 +27,7 @@ public class ShardDataChangePublisherActor extends ShardDataTreeNotificationPublisherActor { private ShardDataChangePublisherActor(final String name, final String logContext) { - super(new DefaultShardDataChangeListenerPublisher(), name, logContext); + super(new DefaultShardDataChangeListenerPublisher(logContext), name, logContext); } @Override @@ -36,7 +36,7 @@ public class ShardDataChangePublisherActor RegisterListener reg = (RegisterListener)message; if (reg.initialState.isPresent()) { DefaultShardDataChangeListenerPublisher.notifySingleListener(reg.path, reg.listener, reg.scope, - reg.initialState.get()); + reg.initialState.get(), logContext()); } publisher().registerDataChangeListener(reg.path, reg.listener, reg.scope, Optional.absent(),