X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDefaultShardDataChangeListenerPublisher.java;h=a94773481d91e3e6353f60572a7b3c1fb9e4ff61;hp=bf52aa14c99431a378fc663ba9bb2c66c79a2723;hb=c3607fd866e5cfde0d4806820981fe95ad29392c;hpb=38402d3e9b8976a40d7926efe47a06243210562f diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DefaultShardDataChangeListenerPublisher.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DefaultShardDataChangeListenerPublisher.java index bf52aa14c9..a94773481d 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DefaultShardDataChangeListenerPublisher.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DefaultShardDataChangeListenerPublisher.java @@ -35,14 +35,16 @@ final class DefaultShardDataChangeListenerPublisher implements ShardDataChangeLi private final ListenerTree dataChangeListenerTree = ListenerTree.create(); @Override - public void submitNotification(final DataChangeListenerRegistration listener, final DOMImmutableDataChangeEvent notification) { + public void submitNotification(final DataChangeListenerRegistration listener, + final DOMImmutableDataChangeEvent notification) { LOG.debug("Notifying listener {} about {}", listener.getInstance(), notification); listener.getInstance().onDataChanged(notification); } @Override - public void submitNotifications(final DataChangeListenerRegistration listener, final Iterable notifications) { + public void submitNotifications(final DataChangeListenerRegistration listener, + final Iterable notifications) { final AsyncDataChangeListener> instance = listener.getInstance(); LOG.debug("Notifying listener {} about {}", instance, notifications); @@ -57,8 +59,9 @@ final class DefaultShardDataChangeListenerPublisher implements ShardDataChangeLi } @Override - public >> DataChangeListenerRegistration - registerDataChangeListener(YangInstanceIdentifier path, L listener, DataChangeScope scope) { + public >> + DataChangeListenerRegistration registerDataChangeListener(YangInstanceIdentifier path, L listener, + DataChangeScope scope) { return dataChangeListenerTree.registerDataChangeListener(path, listener, scope); }