opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/ChangeListenerNotifyTask.java

   1 package org.opendaylight.controller.md.sal.dom.store.impl;
   2
   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;
   8
   9 class ChangeListenerNotifyTask implements Runnable {
  10
  11     private static final Logger LOG = LoggerFactory.getLogger(ChangeListenerNotifyTask.class);
  12     private final Iterable<? extends DataChangeListenerRegistration<?>> listeners;
  13     private final AsyncDataChangeEvent<InstanceIdentifier, NormalizedNode<?, ?>> event;
  14
  15     public ChangeListenerNotifyTask(final Iterable<? extends DataChangeListenerRegistration<?>> listeners,
  16             final AsyncDataChangeEvent<InstanceIdentifier, NormalizedNode<?, ?>> event) {
  17         this.listeners = listeners;
  18         this.event = event;
  19     }
  20
  21     @Override
  22     public void run() {
  23
  24         for (DataChangeListenerRegistration<?> listener : listeners) {
  25             try {
  26                 listener.getInstance().onDataChanged(event);
  27             } catch (Exception e) {
  28                 LOG.error("Unhandled exception during invoking listener {} with event {}", listener, event, e);
  29             }
  30         }
  31
  32     }
  33
  34 }