1 package org.opendaylight.controller.md.sal.dom.store.impl;
3 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
4 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
5 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
6 import org.slf4j.Logger;
7 import org.slf4j.LoggerFactory;
9 class ChangeListenerNotifyTask implements Runnable {
11 private static final Logger LOG = LoggerFactory.getLogger(ChangeListenerNotifyTask.class);
12 private final Iterable<? extends DataChangeListenerRegistration<?>> listeners;
13 private final AsyncDataChangeEvent<InstanceIdentifier, NormalizedNode<?, ?>> event;
15 public ChangeListenerNotifyTask(final Iterable<? extends DataChangeListenerRegistration<?>> listeners,
16 final AsyncDataChangeEvent<InstanceIdentifier, NormalizedNode<?, ?>> event) {
17 this.listeners = listeners;
24 for (DataChangeListenerRegistration<?> listener : listeners) {
26 listener.getInstance().onDataChanged(event);
27 } catch (Exception e) {
28 LOG.error("Unhandled exception during invoking listener {} with event {}", listener, event, e);