add transaction to exists()

[neutron.git] / northbound-api / src / main / java / org / opendaylight / neutron / northbound / api / NeutronLoadBalancerPoolNorthbound.java

diff --git a/northbound-api/src/main/java/org/opendaylight/neutron/northbound/api/NeutronLoadBalancerPoolNorthbound.java b/northbound-api/src/main/java/org/opendaylight/neutron/northbound/api/NeutronLoadBalancerPoolNorthbound.java
index 83ec1f3d46d0bdbd4e220cf5a7786f78d6930cb6..310c59a5062d1310ea9ccc2771573fe2ba1847b4 100644 (file)
--- a/northbound-api/src/main/java/org/opendaylight/neutron/northbound/api/NeutronLoadBalancerPoolNorthbound.java
+++ b/northbound-api/src/main/java/org/opendaylight/neutron/northbound/api/NeutronLoadBalancerPoolNorthbound.java
@@ -25,6 +25,8 @@ import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.Response;
 import org.codehaus.enunciate.jaxrs.ResponseCode;
 import org.codehaus.enunciate.jaxrs.StatusCodes;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
 import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
 import org.opendaylight.neutron.spi.NeutronLoadBalancerPool;
 import org.opendaylight.neutron.spi.NeutronLoadBalancerPoolMember;
@@ -43,9 +45,14 @@ public final class NeutronLoadBalancerPoolNorthbound extends AbstractNeutronNort
 
     private static final String RESOURCE_NAME = "LoadBalancerPool";
 
+    private final DataBroker dataBroker;
+
     @Inject
-    public NeutronLoadBalancerPoolNorthbound(@OsgiService INeutronLoadBalancerPoolCRUD neutronCRUD) {
+    public NeutronLoadBalancerPoolNorthbound(
+            @OsgiService INeutronLoadBalancerPoolCRUD neutronCRUD,
+            @OsgiService DataBroker dataBroker) {
         super(neutronCRUD);
+        this.dataBroker = dataBroker;
     }
 
     @Override
@@ -195,8 +202,10 @@ public final class NeutronLoadBalancerPoolNorthbound extends AbstractNeutronNort
     // sorting not supported
     ) {
         INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
-        if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID)) {
-            throw new ResourceNotFoundException(uuidNoExist());
+        try (ReadOnlyTransaction tx = dataBroker.newReadOnlyTransaction()) {
+            if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID, tx)) {
+                throw new ResourceNotFoundException(uuidNoExist());
+            }
         }
         List<NeutronLoadBalancerPoolMember> members = loadBalancerPoolInterface.get(loadBalancerPoolUUID)
                 .getLoadBalancerPoolMembers();
@@ -241,8 +250,10 @@ public final class NeutronLoadBalancerPoolNorthbound extends AbstractNeutronNort
             @QueryParam("fields") List<String> fields) {
 
         INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
-        if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID)) {
-            throw new ResourceNotFoundException(uuidNoExist());
+        try (ReadOnlyTransaction tx = dataBroker.newReadOnlyTransaction()) {
+            if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID, tx)) {
+                throw new ResourceNotFoundException(uuidNoExist());
+            }
         }
         List<NeutronLoadBalancerPoolMember> members = loadBalancerPoolInterface.get(loadBalancerPoolUUID)
                 .getLoadBalancerPoolMembers();