summaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java
diff options
context:
space:
mode:
authorwasala <przemyslaw.wasala@nokia.com>2018-04-13 14:03:26 +0200
committerPrzemyslaw Wasala <przemyslaw.wasala@nokia.com>2018-04-13 12:34:10 +0000
commit92f9c348d3e51f4032e858c6ae443b70a74e8699 (patch)
tree52f3266b2bf85a4bd43e52d4504ff9291a9ebb60 /prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java
parentcf292d97e6228677024702dd1391cc5fbe759606 (diff)
Extracted high abstraction for tasks
*First of all, all tasks were defined as implementation. *All tasks class have been injected into spring container. Change-Id: I00337b49ed1de3f1b8cadf64f774f19377ae349e Issue-ID: DCAEGEN2-443 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
Diffstat (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java')
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java
index a0739637..99516c46 100644
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java
@@ -20,7 +20,7 @@
package org.onap.dcaegen2.services.prh.controllers;
import java.util.concurrent.ScheduledFuture;
-import org.onap.dcaegen2.services.prh.tasks.ScheduledTask;
+import org.onap.dcaegen2.services.prh.tasks.ScheduledTasks;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
@@ -40,12 +40,12 @@ public class ScheduleController {
private static final int SCHEDULING_DELAY = 20000;
private final TaskScheduler taskScheduler;
- private final ScheduledTask scheduledTask;
+ private final ScheduledTasks scheduledTask;
private ScheduledFuture<?> scheduledFuture;
@Autowired
- public ScheduleController(TaskScheduler taskScheduler, ScheduledTask scheduledTask) {
+ public ScheduleController(TaskScheduler taskScheduler, ScheduledTasks scheduledTask) {
this.taskScheduler = taskScheduler;
this.scheduledTask = scheduledTask;
}
@@ -54,7 +54,7 @@ public class ScheduleController {
@RequestMapping(value = "preferences", method = RequestMethod.PUT)
public ResponseEntity<Void> startTask() {
scheduledFuture = taskScheduler
- .scheduleWithFixedDelay(scheduledTask::scheduledTaskAskingDMaaPOfConsumeEvent, SCHEDULING_DELAY);
+ .scheduleWithFixedDelay(scheduledTask::scheduleMainPrhEventTask, SCHEDULING_DELAY);
return new ResponseEntity<>(HttpStatus.OK);
}