We are required to implement onInitialData() method, add it.
Change-Id: I55e60c9013c49689252f662218db31152982019c
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
.node(Candidate.QNAME).node(Candidate.QNAME).build(), this, Optional.empty(), noop -> { /* NOOP */ });
}
+ @Override
+ public void onInitialData() {
+ // No-op
+ }
+
@Override
public void onDataTreeChanged(final Collection<DataTreeCandidate> changes) {
for (DataTreeCandidate change: changes) {
this.publisher = requireNonNull(publisher);
}
+ @Override
+ public void onInitialData() {
+ // No-op
+ }
+
@Override
public void onDataTreeChanged(final Collection<DataTreeCandidate> changes) {
for (DataTreeCandidate change: changes) {
* finding out how many entities of a given type are owned by a given candidate is not an efficient query.
*/
class EntityOwnershipStatistics extends AbstractEntityOwnerChangeListener {
-
private final TrieMap<String, TrieMap<String, Long>> statistics = TrieMap.create();
EntityOwnershipStatistics() {
// Hidden on purpose
}
+ @Override
+ public void onInitialData() {
+ // No-op
+ }
+
@Override
public void onDataTreeChanged(final Collection<DataTreeCandidate> changes) {
for (DataTreeCandidate change : changes) {
import org.slf4j.LoggerFactory;
public class IdIntsListener implements ClusteredDOMDataTreeChangeListener {
-
private static final Logger LOG = LoggerFactory.getLogger(IdIntsListener.class);
private static final long SECOND_AS_NANO = 1000000000;
private ScheduledExecutorService executorService;
private ScheduledFuture<?> scheduledFuture;
+ @Override
+ public void onInitialData() {
+ // Intentional no-op
+ }
+
@Override
public void onDataTreeChanged(final Collection<DataTreeCandidate> changes) {