aboutsummaryrefslogtreecommitdiffstats
path: root/server/sonar-ce
diff options
context:
space:
mode:
authorJacek <jacek.poreda@sonarsource.com>2019-10-21 15:49:34 -0500
committerSonarTech <sonartech@sonarsource.com>2019-11-12 20:21:06 +0100
commitfc3085b6cb8e80b93842b9742794a11414d11198 (patch)
tree809abed588cbdbcdfc35d61c4b317e85e4a767b6 /server/sonar-ce
parentef59775a55e42caf1cfe6c5064458d15b1890747 (diff)
downloadsonarqube-fc3085b6cb8e80b93842b9742794a11414d11198.tar.gz
sonarqube-fc3085b6cb8e80b93842b9742794a11414d11198.zip
SONAR-12383 Selenide update to 5.2.3 and Guava update to 28.1-jre
Diffstat (limited to 'server/sonar-ce')
-rw-r--r--server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java b/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java
index f75d8aebe9e..5325dd426c5 100644
--- a/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java
+++ b/server/sonar-ce/src/main/java/org/sonar/ce/taskprocessor/CeProcessingSchedulerImpl.java
@@ -23,6 +23,7 @@ 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.ListenableScheduledFuture;
+import com.google.common.util.concurrent.MoreExecutors;
import java.util.Arrays;
import java.util.concurrent.TimeUnit;
import javax.annotation.CheckForNull;
@@ -68,7 +69,7 @@ public class CeProcessingSchedulerImpl implements CeProcessingScheduler {
public void startScheduling() {
for (ChainingCallback chainingCallback : chainingCallbacks) {
ListenableScheduledFuture<CeWorker.Result> future = executorService.schedule(chainingCallback.worker, delayBetweenEnabledTasks, timeUnit);
- addCallback(future, chainingCallback);
+ addCallback(future, chainingCallback, MoreExecutors.directExecutor());
}
}
@@ -200,7 +201,7 @@ public class CeProcessingSchedulerImpl implements CeProcessingScheduler {
private void addCallback() {
if (workerFuture != null) {
- Futures.addCallback(workerFuture, this);
+ Futures.addCallback(workerFuture, this, MoreExecutors.directExecutor());
}
}