refactor #1165, #1386

dcm4che · Jul 25, 2018 · 8f11e00 · 8f11e00
1 parent 3b6d91f
commit 8f11e00
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/dcm4chee-arc-diff-rs/src/main/java/org/dcm4chee/arc/diff/rs/DiffTaskRS.java b/dcm4chee-arc-diff-rs/src/main/java/org/dcm4chee/arc/diff/rs/DiffTaskRS.java
@@ -325,7 +325,7 @@ private int rescheduleTasks(Predicate matchQueueMessage, Predicate matchDiffTask
             } while (count >= rescheduleTasksFetchSize);
             LOG.info("Successfully rescheduled {} tasks on device: {}.", rescheduled, device.getDeviceName());
             queueEvent.setCount(rescheduled);
-            return count;
+            return rescheduled;
         } catch (Exception e) {
             queueEvent.setException(e);
             throw e;

diff --git a/dcm4chee-arc-retrieve-rs/src/main/java/org/dcm4chee/arc/retrieve/rs/RetrieveTaskRS.java b/dcm4chee-arc-retrieve-rs/src/main/java/org/dcm4chee/arc/retrieve/rs/RetrieveTaskRS.java
@@ -293,7 +293,7 @@ private int rescheduleTasks(Predicate matchQueueMessage, Predicate matchRetrieve
             } while (count >= rescheduleTasksFetchSize);
             queueEvent.setCount(rescheduled);
             LOG.info("Successfully rescheduled {} tasks on device: {}.", rescheduled, device.getDeviceName());
-            return count;
+            return rescheduled;
         } catch (Exception e) {
             queueEvent.setException(e);
             throw e;