From 7d9dd56f3eabf5cc8155a9c6ba60c8f1452dfd5e Mon Sep 17 00:00:00 2001
From: Kai Reinhard <K.Reinhard@micromata.de>
Date: Fri, 28 Dec 2018 23:11:11 +0000
Subject: [PATCH] Unchecked warning fixed.
---
borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java | 2 +-
borgbutler-core/src/main/java/de/micromata/borgbutler/BorgQueueExecutor.java | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/borgbutler-core/src/main/java/de/micromata/borgbutler/BorgQueueExecutor.java b/borgbutler-core/src/main/java/de/micromata/borgbutler/BorgQueueExecutor.java
index 96daca2..c7acd5f 100644
--- a/borgbutler-core/src/main/java/de/micromata/borgbutler/BorgQueueExecutor.java
+++ b/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;
diff --git a/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java b/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java
index 7ee6634..6c33bae 100644
--- a/borgbutler-core/src/main/java/de/micromata/borgbutler/jobs/JobQueue.java
+++ b/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())) {
--
Gitblit v1.10.0