update deprecated transform and addCallback methods

[groupbasedpolicy.git] / groupbasedpolicy / src / main / java / org / opendaylight / groupbasedpolicy / base_endpoint / BaseEndpointServiceImpl.java

diff --git a/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/base_endpoint/BaseEndpointServiceImpl.java b/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/base_endpoint/BaseEndpointServiceImpl.java
index 38a78b5cebc81210f84d8548ba20d80dfc56c2e2..d8e05be52aa87a191eac0de9ca03cbae57101f43 100644 (file)
--- a/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/base_endpoint/BaseEndpointServiceImpl.java
+++ b/groupbasedpolicy/src/main/java/org/opendaylight/groupbasedpolicy/base_endpoint/BaseEndpointServiceImpl.java
@@ -58,6 +58,7 @@ import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 
 public class BaseEndpointServiceImpl implements BaseEndpointService, AutoCloseable {
 
@@ -65,13 +66,8 @@ public class BaseEndpointServiceImpl implements BaseEndpointService, AutoCloseab
     private final DataBroker dataProvider;
     private final EndpointAugmentorRegistryImpl epAugRegistry;
 
-    private static final Function<Void, RpcResult<Void>> TO_SUCCESS_RPC_RESULT = new Function<Void, RpcResult<Void>>() {
-
-        @Override
-        public RpcResult<Void> apply(Void input) {
-            return RpcResultBuilder.<Void>success().build();
-        }
-    };
+    private static final Function<Void, RpcResult<Void>> TO_SUCCESS_RPC_RESULT =
+        input -> RpcResultBuilder.<Void>success().build();
 
     public BaseEndpointServiceImpl(DataBroker dataProvider, EndpointAugmentorRegistryImpl epAugRegistry) {
         this.epAugRegistry = Preconditions.checkNotNull(epAugRegistry);
@@ -115,7 +111,7 @@ public class BaseEndpointServiceImpl implements BaseEndpointService, AutoCloseab
             addAddressEndpointToParents(t, endpoint);
         }
 
-        return Futures.transform(t.submit(), TO_SUCCESS_RPC_RESULT);
+        return Futures.transform(t.submit(), TO_SUCCESS_RPC_RESULT, MoreExecutors.directExecutor());
     }
 
     private void addContainmentEndpointToChilds(ReadWriteTransaction t, ContainmentEndpoint endpoint) {
@@ -265,7 +261,7 @@ public class BaseEndpointServiceImpl implements BaseEndpointService, AutoCloseab
         }
 
         ListenableFuture<Void> r = t.submit();
-        return Futures.transform(r, TO_SUCCESS_RPC_RESULT);
+        return Futures.transform(r, TO_SUCCESS_RPC_RESULT, MoreExecutors.directExecutor());
     }
 
     private void deleteAddressEndpointFromParents(ReadWriteTransaction t, AddressEndpoint endpoint) {