diff options
author | k.kedron <k.kedron@partner.samsung.com> | 2021-09-20 10:06:26 +0200 |
---|---|---|
committer | k.kedron <k.kedron@partner.samsung.com> | 2021-09-20 13:04:05 +0200 |
commit | b7e91e0a92ecc0254bb66d560e38cf06e6f76ebb (patch) | |
tree | 690c4526ada4fa8754df770f2397fc08e5bec04a /src/main/java | |
parent | f1563a03cabc572d1cd15260befdaa8808048fbf (diff) |
Refactoring
- ves to report package
- fileready to pm package
- according method name
Issue-ID: INT-1945
Signed-off-by: Krystian Kedron <k.kedron@partner.samsung.com>
Change-Id: I2f22c828145727ba772440fe111b5fde34446b3a
Diffstat (limited to 'src/main/java')
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/controller/RanCellController.java | 32 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/controller/RanEventConfigureController.java | 18 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/data/fileready/RanPeriodicSendReport.java | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/a1/SetLowRangeValuesOnPolicyAction.java | 6 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/cell/RanCellServiceImpl.java | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/common/AbstractRanRunnable.java | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/pm/FileReadyEventService.java (renamed from src/main/java/org/onap/a1pesimulator/service/fileready/FileReadyEventService.java) | 4 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/pm/FtpServerService.java (renamed from src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/pm/PMBulkFileService.java (renamed from src/main/java/org/onap/a1pesimulator/service/fileready/PMBulkFileService.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/pm/RanFileReadyHolder.java (renamed from src/main/java/org/onap/a1pesimulator/service/fileready/RanFileReadyHolder.java) | 4 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/pm/RanSaveFileReadyRunnable.java (renamed from src/main/java/org/onap/a1pesimulator/service/fileready/RanSaveFileReadyRunnable.java) | 4 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/pm/RanSendReportsRunnable.java (renamed from src/main/java/org/onap/a1pesimulator/service/fileready/RanSendReportsRunnable.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/OnEventAction.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/OnEventAction.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanCellEventCustomizer.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanCellEventCustomizer.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanCellFailureEventCustomizer.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanCellFailureEventCustomizer.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanCheckCellIsDeadOnEvent.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanCheckCellIsDeadOnEvent.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanEventCustomizerFactory.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanEventCustomizerFactory.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanReportsBrokerService.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanVesBrokerService.java) | 10 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanReportsBrokerServiceImpl.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanVesBrokerServiceImpl.java) | 12 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanSendVesRunnable.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanSendVesRunnable.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanVesDataProvider.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanVesDataProvider.java) | 2 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanVesHolder.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java) | 10 | ||||
-rw-r--r-- | src/main/java/org/onap/a1pesimulator/service/report/RanVesSender.java (renamed from src/main/java/org/onap/a1pesimulator/service/ves/RanVesSender.java) | 2 |
23 files changed, 64 insertions, 64 deletions
diff --git a/src/main/java/org/onap/a1pesimulator/controller/RanCellController.java b/src/main/java/org/onap/a1pesimulator/controller/RanCellController.java index 10dfe2b..0074058 100644 --- a/src/main/java/org/onap/a1pesimulator/controller/RanCellController.java +++ b/src/main/java/org/onap/a1pesimulator/controller/RanCellController.java @@ -22,7 +22,7 @@ import org.onap.a1pesimulator.data.fileready.RanPeriodicEvent; import org.onap.a1pesimulator.data.ves.VesEvent; import org.onap.a1pesimulator.service.cell.RanCellService; import org.onap.a1pesimulator.service.cell.RanCellStateService; -import org.onap.a1pesimulator.service.ves.RanVesBrokerService; +import org.onap.a1pesimulator.service.report.RanReportsBrokerService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.http.ResponseEntity; @@ -44,13 +44,13 @@ public class RanCellController { private static final Logger log = LoggerFactory.getLogger(RanCellController.class); private final RanCellService ranCellService; private final RanCellStateService ranCellStateService; - private final RanVesBrokerService ranVesBrokerService; + private final RanReportsBrokerService ranReportsBrokerService; public RanCellController(RanCellService ranCellService, RanCellStateService ranCellStateService, - RanVesBrokerService ranVesBrokerService) { + RanReportsBrokerService ranReportsBrokerService) { this.ranCellService = ranCellService; this.ranCellStateService = ranCellStateService; - this.ranVesBrokerService = ranVesBrokerService; + this.ranReportsBrokerService = ranReportsBrokerService; } @GetMapping @@ -65,11 +65,11 @@ public class RanCellController { @ApiOperation("Start sending failure VES events for specific cell") @PostMapping(value = "/{identifier}/startFailure") - public ResponseEntity<String> startSendingFailureVesEvents(@ApiParam(value = "Cell Id") final @PathVariable String identifier, + public ResponseEntity<String> startSendingFailureReports(@ApiParam(value = "Cell Id") final @PathVariable String identifier, @ApiParam(value = "Reporting Method", defaultValue = "FILE_READY", required = true) final @RequestParam() ReportingMethodEnum reportingMethod) { checkIfCellExistOrThrowException(identifier); ranCellService.failure(identifier); - ranVesBrokerService.startSendingFailureVesEvents(identifier, reportingMethod); + ranReportsBrokerService.startSendingFailureReports(identifier, reportingMethod); ranCellStateService.failingState(identifier); return ResponseEntity.accepted().body("Failure VES Event sending started"); @@ -77,11 +77,11 @@ public class RanCellController { @ApiOperation("Stop sending failure VES events for specific cell") @PostMapping(value = "/{identifier}/stopFailure") - public ResponseEntity<Void> stopSendingFailureVesEvents(@ApiParam(value = "Cell Id") final @PathVariable String identifier) { + public ResponseEntity<Void> stopSendingFailureReports(@ApiParam(value = "Cell Id") final @PathVariable String identifier) { checkIfCellExistOrThrowException(identifier); ranCellService.recoverFromFailure(identifier); - Optional<RanPeriodicEvent> vesEvent = ranVesBrokerService.stopSendingVesEvents(identifier); + Optional<RanPeriodicEvent> vesEvent = ranReportsBrokerService.stopSendingReports(identifier); if (!vesEvent.isPresent()) { return ResponseEntity.notFound().build(); @@ -93,17 +93,17 @@ public class RanCellController { @ApiOperation("Start sending normal VES events for specific cell and in specific granularity period") @PostMapping(value = "/{identifier}/start") - public ResponseEntity<String> startSendingVesEvents(@ApiParam(value = "Standard Measurement Event JSON") final @RequestBody Optional<VesEvent> vesEventOpt, + public ResponseEntity<String> startSendingReports(@ApiParam(value = "Standard Measurement Event JSON") final @RequestBody Optional<VesEvent> vesEventOpt, @ApiParam(value = "Cell Id") final @PathVariable String identifier, @ApiParam(value = "Granularity period in seconds", example = "60") final @RequestParam(required = false) Integer interval, @ApiParam(value = "Reporting Method", defaultValue = "FILE_READY", required = true) final @RequestParam() ReportingMethodEnum reportingMethod) { checkIfCellExistOrThrowException(identifier); log.info("Start sending ves events every {} seconds for {} ", getInterval(interval), identifier); - VesEvent vesEvent = vesEventOpt.orElse(ranVesBrokerService.getGlobalPmVesStructure()); + VesEvent vesEvent = vesEventOpt.orElse(ranReportsBrokerService.getGlobalPmVesStructure()); ResponseEntity<String> responseEntity = - ranVesBrokerService.startSendingVesEvents(identifier, vesEvent, getInterval(interval), reportingMethod); + ranReportsBrokerService.startSendingReports(identifier, vesEvent, getInterval(interval), reportingMethod); if (!responseEntity.getStatusCode().is2xxSuccessful()) { return responseEntity; } @@ -114,10 +114,10 @@ public class RanCellController { @ApiOperation("Stop sending normal VES events for specific cell") @PostMapping(value = "/{identifier}/stop") - public ResponseEntity<Void> stopSendingVesEvents(@ApiParam(value = "Cell Id") final @PathVariable String identifier) { + public ResponseEntity<Void> stopSendingReports(@ApiParam(value = "Cell Id") final @PathVariable String identifier) { checkIfCellExistOrThrowException(identifier); log.info("Stop sending custom ves events for {}", identifier); - Optional<RanPeriodicEvent> vesEvent = ranVesBrokerService.stopSendingVesEvents(identifier); + Optional<RanPeriodicEvent> vesEvent = ranReportsBrokerService.stopSendingReports(identifier); if (!vesEvent.isPresent()) { return ResponseEntity.notFound().build(); } @@ -129,15 +129,15 @@ public class RanCellController { @GetMapping(value = "/{identifier}/pmConfig") public ResponseEntity<RanPeriodicEvent> getPMConfig(final @PathVariable String identifier) { checkIfCellExistOrThrowException(identifier); - if (!ranVesBrokerService.getEnabledEventElementIdentifiers().contains(identifier)) { + if (!ranReportsBrokerService.getEnabledEventElementIdentifiers().contains(identifier)) { return ResponseEntity.notFound().build(); } - return ResponseEntity.ok(ranVesBrokerService.getPeriodicEvent(identifier)); + return ResponseEntity.ok(ranReportsBrokerService.getPeriodicEvent(identifier)); } private Integer getInterval(Integer requested) { if (requested == null) { - return ranVesBrokerService.getGlobalVesInterval(); + return ranReportsBrokerService.getGlobalVesInterval(); } return requested; } diff --git a/src/main/java/org/onap/a1pesimulator/controller/RanEventConfigureController.java b/src/main/java/org/onap/a1pesimulator/controller/RanEventConfigureController.java index 5b5037c..79bddf0 100644 --- a/src/main/java/org/onap/a1pesimulator/controller/RanEventConfigureController.java +++ b/src/main/java/org/onap/a1pesimulator/controller/RanEventConfigureController.java @@ -14,7 +14,7 @@ package org.onap.a1pesimulator.controller; import org.onap.a1pesimulator.data.ves.GlobalVesConfiguration; -import org.onap.a1pesimulator.service.ves.RanVesBrokerService; +import org.onap.a1pesimulator.service.report.RanReportsBrokerService; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; @@ -26,24 +26,24 @@ import org.springframework.web.bind.annotation.RestController; @RequestMapping({"${restapi.version}/ran/globalPMConfig"}) public class RanEventConfigureController { - private final RanVesBrokerService ranVesBrokerService; + private final RanReportsBrokerService ranReportsBrokerService; - public RanEventConfigureController(RanVesBrokerService ranVesBrokerService) { - this.ranVesBrokerService = ranVesBrokerService; + public RanEventConfigureController(RanReportsBrokerService ranReportsBrokerService) { + this.ranReportsBrokerService = ranReportsBrokerService; } @GetMapping public ResponseEntity<GlobalVesConfiguration> getGlobalPMConfig() { - GlobalVesConfiguration config = new GlobalVesConfiguration(ranVesBrokerService.getGlobalVesInterval(), - ranVesBrokerService.getGlobalPmVesStructure(), ranVesBrokerService.getGlobalReportingMethod()); + GlobalVesConfiguration config = new GlobalVesConfiguration(ranReportsBrokerService.getGlobalVesInterval(), + ranReportsBrokerService.getGlobalPmVesStructure(), ranReportsBrokerService.getGlobalReportingMethod()); return ResponseEntity.ok(config); } @PostMapping public ResponseEntity<Void> setGlobalPMConfig(final @RequestBody GlobalVesConfiguration config) { - ranVesBrokerService.setGlobalPmVesStructure(config.getEvent()); - ranVesBrokerService.setGlobalVesInterval(config.getInterval()); - ranVesBrokerService.setGlobalReportingMethod(config.getReportingMethod()); + ranReportsBrokerService.setGlobalPmVesStructure(config.getEvent()); + ranReportsBrokerService.setGlobalVesInterval(config.getInterval()); + ranReportsBrokerService.setGlobalReportingMethod(config.getReportingMethod()); return ResponseEntity.ok().build(); } } diff --git a/src/main/java/org/onap/a1pesimulator/data/fileready/RanPeriodicSendReport.java b/src/main/java/org/onap/a1pesimulator/data/fileready/RanPeriodicSendReport.java index ca812e7..c51dc1c 100644 --- a/src/main/java/org/onap/a1pesimulator/data/fileready/RanPeriodicSendReport.java +++ b/src/main/java/org/onap/a1pesimulator/data/fileready/RanPeriodicSendReport.java @@ -15,7 +15,7 @@ package org.onap.a1pesimulator.data.fileready; import java.util.concurrent.ScheduledFuture; -import org.onap.a1pesimulator.service.fileready.RanSendReportsRunnable; +import org.onap.a1pesimulator.service.pm.RanSendReportsRunnable; import lombok.Builder; import lombok.Data; diff --git a/src/main/java/org/onap/a1pesimulator/service/a1/SetLowRangeValuesOnPolicyAction.java b/src/main/java/org/onap/a1pesimulator/service/a1/SetLowRangeValuesOnPolicyAction.java index 29c55de..ab5002d 100644 --- a/src/main/java/org/onap/a1pesimulator/service/a1/SetLowRangeValuesOnPolicyAction.java +++ b/src/main/java/org/onap/a1pesimulator/service/a1/SetLowRangeValuesOnPolicyAction.java @@ -18,7 +18,7 @@ import java.util.List; import org.onap.a1pesimulator.data.fileready.RanPeriodicEvent; import org.onap.a1pesimulator.data.ves.VesEvent; import org.onap.a1pesimulator.data.ves.MeasurementFields.AdditionalMeasurement; -import org.onap.a1pesimulator.service.ves.RanVesBrokerService; +import org.onap.a1pesimulator.service.report.RanReportsBrokerService; import org.onap.a1pesimulator.util.JsonUtils; import org.onap.a1pesimulator.util.RanVesUtils; import org.springframework.stereotype.Service; @@ -26,9 +26,9 @@ import org.springframework.stereotype.Service; @Service public class SetLowRangeValuesOnPolicyAction implements OnPolicyAction { - private final RanVesBrokerService vesBrokerService; + private final RanReportsBrokerService vesBrokerService; - public SetLowRangeValuesOnPolicyAction(RanVesBrokerService vesBrokerService) { + public SetLowRangeValuesOnPolicyAction(RanReportsBrokerService vesBrokerService) { this.vesBrokerService = vesBrokerService; } diff --git a/src/main/java/org/onap/a1pesimulator/service/cell/RanCellServiceImpl.java b/src/main/java/org/onap/a1pesimulator/service/cell/RanCellServiceImpl.java index 0c0ab00..10a598c 100644 --- a/src/main/java/org/onap/a1pesimulator/service/cell/RanCellServiceImpl.java +++ b/src/main/java/org/onap/a1pesimulator/service/cell/RanCellServiceImpl.java @@ -23,7 +23,7 @@ import org.onap.a1pesimulator.data.cell.CellWithStatus; import org.onap.a1pesimulator.data.cell.RanCell; import org.onap.a1pesimulator.data.ue.UserEquipment; import org.onap.a1pesimulator.service.ue.RanUeHolder; -import org.onap.a1pesimulator.service.ves.RanVesHolder; +import org.onap.a1pesimulator.service.report.RanVesHolder; import org.springframework.stereotype.Service; @Service diff --git a/src/main/java/org/onap/a1pesimulator/service/common/AbstractRanRunnable.java b/src/main/java/org/onap/a1pesimulator/service/common/AbstractRanRunnable.java index bd5e2a9..700d336 100644 --- a/src/main/java/org/onap/a1pesimulator/service/common/AbstractRanRunnable.java +++ b/src/main/java/org/onap/a1pesimulator/service/common/AbstractRanRunnable.java @@ -16,7 +16,7 @@ package org.onap.a1pesimulator.service.common; import java.util.Collection; import org.onap.a1pesimulator.data.ves.VesEvent; -import org.onap.a1pesimulator.service.ves.OnEventAction; +import org.onap.a1pesimulator.service.report.OnEventAction; public abstract class AbstractRanRunnable implements Runnable { diff --git a/src/main/java/org/onap/a1pesimulator/service/fileready/FileReadyEventService.java b/src/main/java/org/onap/a1pesimulator/service/pm/FileReadyEventService.java index 98f0733..df2ce97 100644 --- a/src/main/java/org/onap/a1pesimulator/service/fileready/FileReadyEventService.java +++ b/src/main/java/org/onap/a1pesimulator/service/pm/FileReadyEventService.java @@ -11,9 +11,9 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.fileready; +package org.onap.a1pesimulator.service.pm; -import static org.onap.a1pesimulator.service.fileready.FtpServerService.deletePMBulkFile; +import static org.onap.a1pesimulator.service.pm.FtpServerService.deletePMBulkFile; import static org.onap.a1pesimulator.util.Constants.FILE_READY_CHANGE_IDENTIFIER; import static org.onap.a1pesimulator.util.Constants.FILE_READY_CHANGE_TYPE; diff --git a/src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java b/src/main/java/org/onap/a1pesimulator/service/pm/FtpServerService.java index c02ffc3..01b0672 100644 --- a/src/main/java/org/onap/a1pesimulator/service/fileready/FtpServerService.java +++ b/src/main/java/org/onap/a1pesimulator/service/pm/FtpServerService.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.fileready; +package org.onap.a1pesimulator.service.pm; import static java.util.Objects.nonNull; import static org.onap.a1pesimulator.util.Constants.TEMP_DIR; diff --git a/src/main/java/org/onap/a1pesimulator/service/fileready/PMBulkFileService.java b/src/main/java/org/onap/a1pesimulator/service/pm/PMBulkFileService.java index 813c8a4..aec473c 100644 --- a/src/main/java/org/onap/a1pesimulator/service/fileready/PMBulkFileService.java +++ b/src/main/java/org/onap/a1pesimulator/service/pm/PMBulkFileService.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.fileready; +package org.onap.a1pesimulator.service.pm; import static java.util.Comparator.comparing; import static java.util.Objects.isNull; diff --git a/src/main/java/org/onap/a1pesimulator/service/fileready/RanFileReadyHolder.java b/src/main/java/org/onap/a1pesimulator/service/pm/RanFileReadyHolder.java index cf3cf3a..d3a7970 100644 --- a/src/main/java/org/onap/a1pesimulator/service/fileready/RanFileReadyHolder.java +++ b/src/main/java/org/onap/a1pesimulator/service/pm/RanFileReadyHolder.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.fileready; +package org.onap.a1pesimulator.service.pm; import static java.util.Objects.isNull; import static java.util.Objects.nonNull; @@ -27,7 +27,7 @@ import org.onap.a1pesimulator.data.fileready.EventMemoryHolder; import org.onap.a1pesimulator.data.fileready.FileData; import org.onap.a1pesimulator.data.ves.VesEvent; import org.onap.a1pesimulator.exception.VesBrokerException; -import org.onap.a1pesimulator.service.ves.RanVesSender; +import org.onap.a1pesimulator.service.report.RanVesSender; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Service; diff --git a/src/main/java/org/onap/a1pesimulator/service/fileready/RanSaveFileReadyRunnable.java b/src/main/java/org/onap/a1pesimulator/service/pm/RanSaveFileReadyRunnable.java index 53d4600..222680f 100644 --- a/src/main/java/org/onap/a1pesimulator/service/fileready/RanSaveFileReadyRunnable.java +++ b/src/main/java/org/onap/a1pesimulator/service/pm/RanSaveFileReadyRunnable.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.fileready; +package org.onap.a1pesimulator.service.pm; import java.util.Collection; import java.util.UUID; @@ -20,7 +20,7 @@ import org.onap.a1pesimulator.data.ves.VesEvent; import org.onap.a1pesimulator.exception.VesBrokerException; import org.onap.a1pesimulator.service.common.AbstractRanRunnable; import org.onap.a1pesimulator.service.common.EventCustomizer; -import org.onap.a1pesimulator.service.ves.OnEventAction; +import org.onap.a1pesimulator.service.report.OnEventAction; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/org/onap/a1pesimulator/service/fileready/RanSendReportsRunnable.java b/src/main/java/org/onap/a1pesimulator/service/pm/RanSendReportsRunnable.java index f92d479..88cb5a2 100644 --- a/src/main/java/org/onap/a1pesimulator/service/fileready/RanSendReportsRunnable.java +++ b/src/main/java/org/onap/a1pesimulator/service/pm/RanSendReportsRunnable.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.fileready; +package org.onap.a1pesimulator.service.pm; public class RanSendReportsRunnable implements Runnable { diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/OnEventAction.java b/src/main/java/org/onap/a1pesimulator/service/report/OnEventAction.java index ba1ddab..f95f749 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/OnEventAction.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/OnEventAction.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import org.onap.a1pesimulator.data.ves.VesEvent; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanCellEventCustomizer.java b/src/main/java/org/onap/a1pesimulator/service/report/RanCellEventCustomizer.java index 7cb375f..f16e29c 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanCellEventCustomizer.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanCellEventCustomizer.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import java.util.List; import java.util.Optional; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanCellFailureEventCustomizer.java b/src/main/java/org/onap/a1pesimulator/service/report/RanCellFailureEventCustomizer.java index a21d1ad..6d62f33 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanCellFailureEventCustomizer.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanCellFailureEventCustomizer.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import java.text.MessageFormat; import java.util.Collection; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanCheckCellIsDeadOnEvent.java b/src/main/java/org/onap/a1pesimulator/service/report/RanCheckCellIsDeadOnEvent.java index 3d0c400..a3fc3da 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanCheckCellIsDeadOnEvent.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanCheckCellIsDeadOnEvent.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import static org.onap.a1pesimulator.service.cell.RanCellStateService.TOPIC_CELL; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanEventCustomizerFactory.java b/src/main/java/org/onap/a1pesimulator/service/report/RanEventCustomizerFactory.java index c7c2ee9..26ec13a 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanEventCustomizerFactory.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanEventCustomizerFactory.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import java.text.MessageFormat; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesBrokerService.java b/src/main/java/org/onap/a1pesimulator/service/report/RanReportsBrokerService.java index 1b92fbf..a1af9ac 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesBrokerService.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanReportsBrokerService.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import java.util.Collection; import java.util.Map; @@ -22,11 +22,11 @@ import org.onap.a1pesimulator.data.fileready.RanPeriodicEvent; import org.onap.a1pesimulator.data.ves.VesEvent; import org.springframework.http.ResponseEntity; -public interface RanVesBrokerService { +public interface RanReportsBrokerService { - ResponseEntity<String> startSendingVesEvents(String identifier, VesEvent vesEvent, Integer interval, ReportingMethodEnum reportingMethods); + ResponseEntity<String> startSendingReports(String identifier, VesEvent vesEvent, Integer interval, ReportingMethodEnum reportingMethods); - Optional<RanPeriodicEvent> stopSendingVesEvents(String identifier); + Optional<RanPeriodicEvent> stopSendingReports(String identifier); Map<String, RanPeriodicEvent> getPeriodicEventsCache(); @@ -34,7 +34,7 @@ public interface RanVesBrokerService { RanPeriodicEvent getPeriodicEvent(String identifier); - VesEvent startSendingFailureVesEvents(String identifier, ReportingMethodEnum reportingMethods); + VesEvent startSendingFailureReports(String identifier, ReportingMethodEnum reportingMethods); VesEvent getGlobalPmVesStructure(); diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesBrokerServiceImpl.java b/src/main/java/org/onap/a1pesimulator/service/report/RanReportsBrokerServiceImpl.java index ea4b46d..b441164 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesBrokerServiceImpl.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanReportsBrokerServiceImpl.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import java.util.Collection; import java.util.Collections; @@ -27,13 +27,13 @@ import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Service; @Service -public class RanVesBrokerServiceImpl implements RanVesBrokerService { +public class RanReportsBrokerServiceImpl implements RanReportsBrokerService { private final RanVesDataProvider vesDataProvider; private final RanVesHolder vesHolder; - public RanVesBrokerServiceImpl(RanVesDataProvider vesDataProvider, RanVesHolder vesHolder) { + public RanReportsBrokerServiceImpl(RanVesDataProvider vesDataProvider, RanVesHolder vesHolder) { this.vesDataProvider = vesDataProvider; this.vesHolder = vesHolder; } @@ -44,14 +44,14 @@ public class RanVesBrokerServiceImpl implements RanVesBrokerService { } @Override - public ResponseEntity<String> startSendingVesEvents(String identifier, VesEvent vesEvent, Integer interval, ReportingMethodEnum reportingMethod) { + public ResponseEntity<String> startSendingReports(String identifier, VesEvent vesEvent, Integer interval, ReportingMethodEnum reportingMethod) { enrichWithIdentifier(identifier, vesEvent); ResponseEntity<String> response = vesHolder.startSendingVesEvents(identifier, vesEvent, interval, reportingMethod); return ResponseEntity.accepted().body(response.getBody()); } @Override - public VesEvent startSendingFailureVesEvents(String identifier, ReportingMethodEnum reportingMethod) { + public VesEvent startSendingFailureReports(String identifier, ReportingMethodEnum reportingMethod) { var vesEvent = vesDataProvider.getFailurePmVesEvent(); @@ -61,7 +61,7 @@ public class RanVesBrokerServiceImpl implements RanVesBrokerService { } @Override - public Optional<RanPeriodicEvent> stopSendingVesEvents(String identifier) { + public Optional<RanPeriodicEvent> stopSendingReports(String identifier) { return vesHolder.stopSendingVesEvents(identifier); } diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanSendVesRunnable.java b/src/main/java/org/onap/a1pesimulator/service/report/RanSendVesRunnable.java index c537a5f..e982417 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanSendVesRunnable.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanSendVesRunnable.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import java.util.Collection; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesDataProvider.java b/src/main/java/org/onap/a1pesimulator/service/report/RanVesDataProvider.java index 931b258..35f2773 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesDataProvider.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanVesDataProvider.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import java.io.IOException; import java.net.URL; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java b/src/main/java/org/onap/a1pesimulator/service/report/RanVesHolder.java index 92d30e4..dba7898 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesHolder.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanVesHolder.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import static java.util.Objects.isNull; import static java.util.Objects.nonNull; @@ -31,10 +31,10 @@ import org.onap.a1pesimulator.data.fileready.RanPeriodicSendReport; import org.onap.a1pesimulator.data.ves.VesEvent; import org.onap.a1pesimulator.service.common.AbstractRanRunnable; import org.onap.a1pesimulator.service.common.EventCustomizer; -import org.onap.a1pesimulator.service.fileready.RanFileReadyHolder; -import org.onap.a1pesimulator.service.fileready.RanSaveFileReadyRunnable; -import org.onap.a1pesimulator.service.fileready.RanSendReportsRunnable; -import org.onap.a1pesimulator.service.ves.RanEventCustomizerFactory.Mode; +import org.onap.a1pesimulator.service.pm.RanFileReadyHolder; +import org.onap.a1pesimulator.service.pm.RanSaveFileReadyRunnable; +import org.onap.a1pesimulator.service.pm.RanSendReportsRunnable; +import org.onap.a1pesimulator.service.report.RanEventCustomizerFactory.Mode; import org.onap.a1pesimulator.util.VnfConfigReader; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesSender.java b/src/main/java/org/onap/a1pesimulator/service/report/RanVesSender.java index 85bccbb..d12abd8 100644 --- a/src/main/java/org/onap/a1pesimulator/service/ves/RanVesSender.java +++ b/src/main/java/org/onap/a1pesimulator/service/report/RanVesSender.java @@ -11,7 +11,7 @@ * limitations under the License */ -package org.onap.a1pesimulator.service.ves; +package org.onap.a1pesimulator.service.report; import static java.util.Objects.nonNull; |