From 85e946e076184ce6166cf07f66190ac1f3f59475 Mon Sep 17 00:00:00 2001
From: Kai Reinhard <K.Reinhard@micromata.de>
Date: Tue, 18 Dec 2018 23:55:32 +0000
Subject: [PATCH] Queuing...
---
borgbutler-core/src/main/java/de/micromata/borgbutler/BorgCommands.java | 9 +++++++--
1 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/borgbutler-core/src/main/java/de/micromata/borgbutler/BorgCommands.java b/borgbutler-core/src/main/java/de/micromata/borgbutler/BorgCommands.java
index 4a7806a..4bffa3a 100644
--- a/borgbutler-core/src/main/java/de/micromata/borgbutler/BorgCommands.java
+++ b/borgbutler-core/src/main/java/de/micromata/borgbutler/BorgCommands.java
@@ -10,6 +10,7 @@
import de.micromata.borgbutler.utils.ReplaceUtils;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.io.output.ByteArrayOutputStream;
+import org.apache.commons.lang3.Validate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -173,10 +174,14 @@
}
private static String execute(BorgCommand command) {
- return BorgExecutorQueue.getInstance().execute(command);
+ Validate.notNull(command);
+ Validate.notNull(command.repoConfig);
+ return BorgExecutorQueue.getQueue(command.repoConfig).execute(command);
}
private static void execute(OutputStream outputStream, BorgCommand command) {
- BorgExecutorQueue.getInstance().execute(outputStream, command);
+ Validate.notNull(command);
+ Validate.notNull(command.repoConfig);
+ BorgExecutorQueue.getQueue(command.repoConfig).execute(outputStream, command);
}
}
--
Gitblit v1.10.0