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;
public class NodeManager {
public void onFailure(@Nullable Throwable throwable) {
LOG.warn("Exception thrown when removing node... {}", throwable);
}
- });
+ }, MoreExecutors.directExecutor());
}
/**
public void onFailure(@Nullable Throwable throwable) {
LOG.warn("Exception thrown when resolving node... {}", throwable);
}
- });
+ }, MoreExecutors.directExecutor());
}
/**