X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fcontrollers%2FServiceController.java;h=464511f4da919b136b9a044c22e9516c38556735;hb=8f1c85c3604a0d10675cacd16a7b67dca346d478;hp=e68b82c3e355d4023a598ec374b0c67db29c1fe5;hpb=b40e1b476b25dfdd5ad3ba235ab085d6d4087be3;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/controllers/ServiceController.java b/policy-agent/src/main/java/org/oransc/policyagent/controllers/ServiceController.java index e68b82c3..464511f4 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/controllers/ServiceController.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/controllers/ServiceController.java @@ -28,8 +28,9 @@ import io.swagger.annotations.ApiResponse; import io.swagger.annotations.ApiResponses; import java.time.Duration; +import java.util.ArrayList; import java.util.Collection; -import java.util.Vector; +import java.util.List; import org.oransc.policyagent.exceptions.ServiceException; import org.oransc.policyagent.repository.Policies; @@ -67,10 +68,10 @@ public class ServiceController { @ApiOperation(value = "Returns service information") @ApiResponses( value = {@ApiResponse(code = 200, message = "OK", response = ServiceStatus.class, responseContainer = "List")}) - public ResponseEntity getServices( // + public ResponseEntity getServices(// @RequestParam(name = "name", required = false) String name) { - Collection servicesStatus = new Vector<>(); + Collection servicesStatus = new ArrayList<>(); synchronized (this.services) { for (Service s : this.services.getAll()) { if (name == null || name.equals(s.getName())) { @@ -80,7 +81,7 @@ public class ServiceController { } String res = gson.toJson(servicesStatus); - return new ResponseEntity(res, HttpStatus.OK); + return new ResponseEntity<>(res, HttpStatus.OK); } private ServiceStatus toServiceStatus(Service s) { @@ -90,29 +91,29 @@ public class ServiceController { @ApiOperation(value = "Register a service") @ApiResponses(value = {@ApiResponse(code = 200, message = "OK", response = String.class)}) @PutMapping("/service") - public ResponseEntity putService( // + public ResponseEntity putService(// @RequestBody ServiceRegistrationInfo registrationInfo) { try { this.services.put(toService(registrationInfo)); - return new ResponseEntity("OK", HttpStatus.OK); + return new ResponseEntity<>("OK", HttpStatus.OK); } catch (Exception e) { - return new ResponseEntity(e.getMessage(), HttpStatus.NO_CONTENT); + return new ResponseEntity<>(e.getMessage(), HttpStatus.NO_CONTENT); } } @ApiOperation(value = "Delete a service") @ApiResponses(value = {@ApiResponse(code = 200, message = "OK")}) @DeleteMapping("/services") - public ResponseEntity deleteService( // - @RequestParam(name = "serviceName", required = true) String serviceName) { + public ResponseEntity deleteService(// + @RequestParam(name = "name", required = true) String serviceName) { try { Service service = removeService(serviceName); // Remove the policies from the repo and let the consistency monitoring // do the rest. removePolicies(service); - return new ResponseEntity("OK", HttpStatus.NO_CONTENT); + return new ResponseEntity<>("OK", HttpStatus.NO_CONTENT); } catch (Exception e) { - return new ResponseEntity(e.getMessage(), HttpStatus.NO_CONTENT); + return new ResponseEntity<>(e.getMessage(), HttpStatus.NO_CONTENT); } } @@ -121,13 +122,13 @@ public class ServiceController { value = {@ApiResponse(code = 200, message = "Policies timeout supervision refreshed"), @ApiResponse(code = 404, message = "The service is not found, needs re-registration")}) @PostMapping("/services/keepalive") - public ResponseEntity keepAliveService( // - @RequestParam(name = "serviceName", required = true) String serviceName) { + public ResponseEntity keepAliveService(// + @RequestParam(name = "name", required = true) String serviceName) { try { services.getService(serviceName).ping(); - return new ResponseEntity("OK", HttpStatus.OK); + return new ResponseEntity<>("OK", HttpStatus.OK); } catch (Exception e) { - return new ResponseEntity(e.getMessage(), HttpStatus.NOT_FOUND); + return new ResponseEntity<>(e.getMessage(), HttpStatus.NOT_FOUND); } } @@ -141,7 +142,7 @@ public class ServiceController { private void removePolicies(Service service) { synchronized (this.policies) { - Vector policyList = new Vector<>(this.policies.getForService(service.getName())); + List policyList = new ArrayList<>(this.policies.getForService(service.getName())); for (Policy policy : policyList) { this.policies.remove(policy); }