diff options
author | 2018-04-13 14:03:26 +0200 | |
---|---|---|
committer | 2018-04-13 12:34:10 +0000 | |
commit | 92f9c348d3e51f4032e858c6ae443b70a74e8699 (patch) | |
tree | 52f3266b2bf85a4bd43e52d4504ff9291a9ebb60 /prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/controllers/ScheduleController.java | |
parent | cf292d97e6228677024702dd1391cc5fbe759606 (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.java | 8 |
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); } |