aboutsummaryrefslogtreecommitdiffstats
path: root/vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java')
-rw-r--r--vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java43
1 files changed, 43 insertions, 0 deletions
diff --git a/vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java b/vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java
new file mode 100644
index 000000000..99754fcde
--- /dev/null
+++ b/vid-app-common/src/main/java/org/onap/vid/scheduler/SchedulerServiceImpl.java
@@ -0,0 +1,43 @@
+package org.onap.vid.scheduler;
+
+import org.onap.vid.aai.ExceptionWithRequestInfo;
+import org.onap.vid.model.probes.ErrorMetadata;
+import org.onap.vid.model.probes.ExternalComponentStatus;
+import org.onap.vid.model.probes.HttpRequestMetadata;
+import org.onap.vid.mso.RestObjectWithRequestInfo;
+import org.onap.vid.services.ChangeManagementService;
+import org.onap.vid.utils.Logging;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class SchedulerServiceImpl implements SchedulerService{
+
+ private final ChangeManagementService changeManagementService;
+
+
+ @Autowired
+ public SchedulerServiceImpl(ChangeManagementService changeManagementService) {
+ this.changeManagementService = changeManagementService;
+ }
+
+ @Override
+ public ExternalComponentStatus probeGetSchedulerChangeManagements() {
+ long startTime = System.currentTimeMillis();
+ try {
+ RestObjectWithRequestInfo response = this.changeManagementService.getSchedulerChangeManagementsWithRequestInfo();
+ return new ExternalComponentStatus(
+ ExternalComponentStatus.Component.SCHEDULER,
+ true,
+ new HttpRequestMetadata(response, "OK", startTime)
+ );
+ } catch (ExceptionWithRequestInfo e) {
+ long duration = System.currentTimeMillis() - startTime;
+ return new ExternalComponentStatus(ExternalComponentStatus.Component.SCHEDULER,
+ false,
+ new HttpRequestMetadata(e, duration));
+ } catch (Exception e) {
+ long duration = System.currentTimeMillis() - startTime;
+ return new ExternalComponentStatus(ExternalComponentStatus.Component.SCHEDULER, false,
+ new ErrorMetadata(Logging.exceptionToDescription(e), duration));
+ }
+ }
+}