update deprecated transform and addCallback methods

[groupbasedpolicy.git] / renderers / ios-xe / src / main / java / org / opendaylight / groupbasedpolicy / renderer / ios_xe_provider / impl / manager / PolicyManagerImpl.java

diff --git a/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/manager/PolicyManagerImpl.java b/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/manager/PolicyManagerImpl.java
index b1d6e3ccc6ebac7292ab4d9a7c99b3a343359fee..37acaa3021e479e32e75d6d3fdeb6385c4c4a114 100644 (file)
--- a/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/manager/PolicyManagerImpl.java
+++ b/renderers/ios-xe/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ios_xe_provider/impl/manager/PolicyManagerImpl.java
@@ -17,6 +17,8 @@ import com.google.common.util.concurrent.AsyncFunction;
 import com.google.common.util.concurrent.CheckedFuture;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
+
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
@@ -93,7 +95,7 @@ public class PolicyManagerImpl implements PolicyManager {
                     }
                     return syncEndpoints(dataAfter, Create);
                 }
-            });
+            }, MoreExecutors.directExecutor());
         }
         return Futures.transformAsync(creationResult, new AsyncFunction<Optional<Status>, Boolean>() {
             @Override
@@ -104,9 +106,9 @@ public class PolicyManagerImpl implements PolicyManager {
                     public Boolean apply(@Nullable final Void input) {
                         return Boolean.TRUE;
                     }
-                });
+                }, MoreExecutors.directExecutor());
             }
-        });
+        }, MoreExecutors.directExecutor());
     }
 
     /**
@@ -225,7 +227,7 @@ public class PolicyManagerImpl implements PolicyManager {
 
                 return Optional.of(status);
             }
-        });
+        }, MoreExecutors.directExecutor());
     }
 
     private CheckedFuture<Void, TransactionCommitFailedException> reportPolicy(final long version,