import com.google.common.base.Optional;
import com.google.common.util.concurrent.CheckedFuture;
import java.util.Map;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
-import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction;
-import org.opendaylight.controller.sal.core.spi.data.DOMStoreTransactionFactory;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
+import org.opendaylight.mdsal.common.api.ReadFailedException;
+import org.opendaylight.mdsal.dom.api.DOMDataTreeReadWriteTransaction;
+import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadWriteTransaction;
+import org.opendaylight.mdsal.dom.spi.store.DOMStoreTransactionFactory;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
-public class DOMBrokerReadWriteTransaction<T extends DOMStoreReadWriteTransaction>
- extends DOMBrokerWriteOnlyTransaction<DOMStoreReadWriteTransaction> implements DOMDataReadWriteTransaction {
+public class DOMBrokerReadWriteTransaction extends AbstractDOMBrokerWriteTransaction<DOMStoreReadWriteTransaction>
+ implements DOMDataTreeReadWriteTransaction {
+
/**
- * Creates new composite Transactions.
+ * Constructs an instance.
*
- * @param identifier Identifier of transaction.
- * @param storeTxFactories
+ * @param identifier identifier of transaction.
+ * @param storeTxFactories the backing transaction store factories
*/
- protected DOMBrokerReadWriteTransaction(Object identifier, Map<LogicalDatastoreType, ? extends DOMStoreTransactionFactory> storeTxFactories, final AbstractDOMTransactionFactory<?> commitImpl) {
+ protected DOMBrokerReadWriteTransaction(Object identifier,
+ Map<LogicalDatastoreType, ? extends DOMStoreTransactionFactory> storeTxFactories,
+ final AbstractDOMTransactionFactory<?> commitImpl) {
super(identifier, storeTxFactories, commitImpl);
}
return getTxFactory(key).newReadWriteTransaction();
}
-
+ @Override
+ public void close() {
+ cancel();
+ }
}