update deprecated transform and addCallback methods

[groupbasedpolicy.git] / sxp-integration / sxp-ise-adapter / src / main / java / org / opendaylight / groupbasedpolicy / sxp_ise_adapter / impl / EPPolicyTemplateProviderIseImpl.java

diff --git a/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/EPPolicyTemplateProviderIseImpl.java b/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/EPPolicyTemplateProviderIseImpl.java
index 1e5c7fa7b9b7f13bf97a23ad6865b463794b08fd..17e09840c243e127dc926bb26416a9766ea92b2b 100644 (file)
--- a/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/EPPolicyTemplateProviderIseImpl.java
+++ b/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/EPPolicyTemplateProviderIseImpl.java
@@ -13,6 +13,8 @@ import com.google.common.collect.Range;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
+
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Optional;
@@ -53,7 +55,7 @@ public class EPPolicyTemplateProviderIseImpl implements EPPolicyTemplateProvider
                 return Optional.ofNullable(input)
                         .flatMap(i -> i.map(sgtName -> buildTemplate(sgt, iseContext.getIseSourceConfig().getTenant(), sgtName)));
             }
-        });
+        }, MoreExecutors.directExecutor());
     }
 
     private EndpointPolicyTemplateBySgt buildTemplate(final @Nonnull Sgt sgt, final @Nonnull TenantId tenantId,
@@ -81,7 +83,7 @@ public class EPPolicyTemplateProviderIseImpl implements EPPolicyTemplateProvider
             public void onFailure(final Throwable t) {
                 LOG.debug("[epPolicyTemplateProvider] harvestAll FAILED: {}", t.getMessage());
             }
-        });
+        }, MoreExecutors.directExecutor());
 
         return Futures.transform(sgtUpdateFu, new Function<Collection<SgtInfo>, Optional<String>>() {
             @Nullable
@@ -93,7 +95,7 @@ public class EPPolicyTemplateProviderIseImpl implements EPPolicyTemplateProvider
                                 .filter(sgtInfo -> sgt.equals(sgtInfo.getSgt())).findFirst()
                                 .map(SgtInfo::getName));
             }
-        });
+        }, MoreExecutors.directExecutor());
     }
 
     private Optional<IseContext> findIseSourceConfigBySgt(final Sgt sgt) {