MDSAL-API Migration

[genius.git] / itm / itm-impl / src / main / java / org / opendaylight / genius / itm / impl / ITMBatchingUtils.java

diff --git a/itm/itm-impl/src/main/java/org/opendaylight/genius/itm/impl/ITMBatchingUtils.java b/itm/itm-impl/src/main/java/org/opendaylight/genius/itm/impl/ITMBatchingUtils.java
index 738409ed1ae85dbde40403bcd44f4efedda75c44..fb8069609c7b411a097f26aa3d6e1c07ade6877d 100644 (file)
--- a/itm/itm-impl/src/main/java/org/opendaylight/genius/itm/impl/ITMBatchingUtils.java
+++ b/itm/itm-impl/src/main/java/org/opendaylight/genius/itm/impl/ITMBatchingUtils.java
@@ -10,12 +10,12 @@ package org.opendaylight.genius.itm.impl;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 import org.eclipse.jdt.annotation.NonNull;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
 import org.opendaylight.genius.utils.batching.ActionableResource;
 import org.opendaylight.genius.utils.batching.ActionableResources;
 import org.opendaylight.genius.utils.batching.DefaultBatchHandler;
 import org.opendaylight.genius.utils.batching.ResourceBatchingManager;
+import org.opendaylight.mdsal.binding.api.DataBroker;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 import org.slf4j.Logger;
@@ -71,6 +71,13 @@ public final class ITMBatchingUtils {
         getQueue(entityType).add(ActionableResources.update(path, data));
     }
 
+    public static <T extends DataObject> void updateContainer(InstanceIdentifier<T> path, T data,
+                                                              EntityType entityType) {
+        LOG.debug("Adding to the Queue to batch the update DS Operation - Id {} data {}", path, data);
+        getQueue(entityType).add(ActionableResources.updateContainer(path, data));
+    }
+
+
     public static <T extends DataObject> void write(InstanceIdentifier<T> path, T data, EntityType entityType) {
         LOG.debug("Adding to the Queue to batch the write DS Operation - Id {} data {}", path, data);
         getQueue(entityType).add(ActionableResources.create(path, data));