opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/DataTransactionImpl.java

   1 package org.opendaylight.controller.sal.binding.impl;
   2
   3 import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
   4 import org.opendaylight.controller.md.sal.common.impl.service.AbstractDataTransaction;
   5 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
   6 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction.DataTransactionListener;
   7 import org.opendaylight.yangtools.concepts.ListenerRegistration;
   8 import org.opendaylight.yangtools.concepts.util.ListenerRegistry;
   9 import org.opendaylight.yangtools.yang.binding.DataObject;
  10 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  11
  12 public class DataTransactionImpl extends AbstractDataTransaction<InstanceIdentifier<? extends DataObject>, DataObject>
  13     implements DataModificationTransaction {
  14     private final ListenerRegistry<DataTransactionListener> listeners = new ListenerRegistry<DataTransactionListener>();
  15
  16
  17
  18     public DataTransactionImpl(Object identifier,DataBrokerImpl dataBroker) {
  19         super(identifier,dataBroker);
  20     }
  21
  22     @Override
  23     public ListenerRegistration<DataTransactionListener> registerListener(DataTransactionListener listener) {
  24         return listeners.register(listener);
  25     }
  26
  27     protected void onStatusChange(TransactionStatus status) {
  28         for (ListenerRegistration<DataTransactionListener> listenerRegistration : listeners) {
  29             listenerRegistration.getInstance().onStatusUpdated(this, status);
  30         }
  31     }
  32 }