update deprecated transform and addCallback methods

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

diff --git a/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/GbpIseSgtHarvesterImpl.java b/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/GbpIseSgtHarvesterImpl.java
index 67e2cef3a92677f1b884b38625218310a422b123..833fd03b891eeaef60d9bdfe229fd73740eecc67 100644 (file)
--- a/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/GbpIseSgtHarvesterImpl.java
+++ b/sxp-integration/sxp-ise-adapter/src/main/java/org/opendaylight/groupbasedpolicy/sxp_ise_adapter/impl/GbpIseSgtHarvesterImpl.java
@@ -12,6 +12,7 @@ import com.google.common.base.Function;
 import com.google.common.util.concurrent.AsyncFunction;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import com.sun.jersey.api.client.Client;
 import com.sun.jersey.api.client.WebResource;
@@ -84,7 +85,7 @@ public class GbpIseSgtHarvesterImpl implements GbpIseSgtHarvester {
                         LOG.debug("entering stg-info processor {}", processor.getClass().getSimpleName());
                         return processor.processSgtInfo(iseSourceConfig.getTenant(), sgtInfos);
                     }
-                });
+                }, MoreExecutors.directExecutor());
             }
             result = Futures.transform(processingResult, new Function<Void, Collection<SgtInfo>>() {
                 @Nullable
@@ -98,7 +99,7 @@ public class GbpIseSgtHarvesterImpl implements GbpIseSgtHarvester {
                     // always success, otherwise there will be TransactionCommitFailedException thrown
                     return sgtInfos;
                 }
-            });
+            }, MoreExecutors.directExecutor());
         } catch (Exception e) {
             LOG.debug("failed to harvest ise", e);
             result = Futures.immediateFailedFuture(e);