1 package org.opendaylight.controller.sal.dom.broker;
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.core.api.data.DataModificationTransaction;
6 import org.opendaylight.yangtools.concepts.ListenerRegistration;
7 import org.opendaylight.yangtools.concepts.util.ListenerRegistry;
8 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
9 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
11 public class DataTransactionImpl extends AbstractDataTransaction<InstanceIdentifier, CompositeNode>
12 implements DataModificationTransaction {
13 private final ListenerRegistry<DataTransactionListener> listeners = new ListenerRegistry<DataTransactionListener>();
17 public DataTransactionImpl(Object identifier,DataBrokerImpl dataBroker) {
18 super(identifier,dataBroker);
22 public ListenerRegistration<DataTransactionListener> registerListener(DataTransactionListener listener) {
23 return listeners.register(listener);
26 protected void onStatusChange(TransactionStatus status) {
27 for (ListenerRegistration<DataTransactionListener> listenerRegistration : listeners) {
28 listenerRegistration.getInstance().onStatusUpdated(this, status);