1 package org.opendaylight.controller.sal.binding.impl;
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;
12 public class DataTransactionImpl extends AbstractDataTransaction<InstanceIdentifier<? extends DataObject>, DataObject>
13 implements DataModificationTransaction {
14 private final ListenerRegistry<DataTransactionListener> listeners = new ListenerRegistry<DataTransactionListener>();
18 public DataTransactionImpl(DataBrokerImpl dataBroker) {
23 public ListenerRegistration<DataTransactionListener> registerListener(DataTransactionListener listener) {
24 return listeners.register(listener);
27 protected void onStatusChange(TransactionStatus status) {
28 for (ListenerRegistration<DataTransactionListener> listenerRegistration : listeners) {
29 listenerRegistration.getInstance().onStatusUpdated(this, status);