mirror of https://github.com/micromata/borgbackup-butler.git

Kai Reinhard
29.11.2018 7d9dd56f3eabf5cc8155a9c6ba60c8f1452dfd5e
Unchecked warning fixed.
2 files modified
10 ■■■■ changed files
borgbutler-core/src/main/java/de/micromata/borgbutler/BorgQueueExecutor.java 8 ●●●● patch | view | raw | blame | history
borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java 2 ●●● patch | view | raw | blame | history
borgbutler-core/src/main/java/de/micromata/borgbutler/BorgQueueExecutor.java
@@ -21,14 +21,14 @@
    }
    // key is the repo name.
    private Map<String, JobQueue> queueMap = new HashMap<>();
    private Map<String, JobQueue<String>> queueMap = new HashMap<>();
    private JobQueue getQueue(BorgRepoConfig config) {
    private JobQueue<String> getQueue(BorgRepoConfig config) {
        synchronized (queueMap) {
            String queueName = config != null ? config.getRepo() : "--NO_REPO--";
            JobQueue queue = queueMap.get(queueName);
            JobQueue<String> queue = queueMap.get(queueName);
            if (queue == null) {
                queue = new JobQueue();
                queue = new JobQueue<>();
                queueMap.put(queueName, queue);
            }
            return queue;
borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java
@@ -30,7 +30,7 @@
     * @param job
     * @return The given job (if it's not already running or queued), otherwise the already running or queued job.
     */
    public AbstractJob append(AbstractJob job) {
    public AbstractJob append(AbstractJob<T> job) {
        synchronized (queue) {
            for (AbstractJob queuedJob : queue) {
                if (Objects.equals(queuedJob.getId(), job.getId())) {