From: Grzegorz Wielgosinski Date: Mon, 30 Aug 2021 08:58:13 +0000 (+0200) Subject: Add 10 seconds latency for mock response in AAI update/delete request X-Git-Tag: 1.9.0~5 X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=29c1e826c4f02259fd7843fdd1fed16538cacc44;p=so%2Fadapters%2Fso-cnf-adapter.git Add 10 seconds latency for mock response in AAI update/delete request Issue-ID: SO-3747 Signed-off-by: Grzegorz Wielgosinski Change-Id: Ia9e20507cec11b7efe483ce8c2e3e141efd62f7a --- diff --git a/so-cnf-adapter-application/src/main/java/org/onap/so/adapters/cnf/rest/CnfAdapterRest.java b/so-cnf-adapter-application/src/main/java/org/onap/so/adapters/cnf/rest/CnfAdapterRest.java index 074fd45..63d9880 100644 --- a/so-cnf-adapter-application/src/main/java/org/onap/so/adapters/cnf/rest/CnfAdapterRest.java +++ b/so-cnf-adapter-application/src/main/java/org/onap/so/adapters/cnf/rest/CnfAdapterRest.java @@ -60,6 +60,7 @@ import org.onap.so.client.exception.BadResponseException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; @@ -106,7 +107,7 @@ public class CnfAdapterRest { logger.info("healthCheck called."); DeferredResult response = new DeferredResult<>(); - ForkJoinPool.commonPool().submit(() -> { + new Thread(() -> { logger.info("Processing healthCheck service"); HealthCheckResponse healthCheckResponse = null; try { @@ -118,7 +119,7 @@ public class CnfAdapterRest { return; } callbackClient.sendPostCallback(healthCheckRequest.getCallbackUrl(), healthCheckResponse); - }); + }).start(); response.setResult(ResponseEntity.accepted().build()); return response; @@ -131,14 +132,18 @@ public class CnfAdapterRest { logger.info("aai-update called."); DeferredResult response = new DeferredResult<>(); - ForkJoinPool.commonPool().submit(() -> { + new Thread(() -> { logger.info("Processing aai update"); // aaiService.aaiUpdate(aaiRequest); AaiCallbackResponse mockCallbackResponse = new AaiCallbackResponse(); mockCallbackResponse.setCompletionStatus(AaiCallbackResponse.CompletionStatus.COMPLETED); + try { + Thread.sleep(10_000L); + } catch (InterruptedException e) { + logger.error("InterruptedException occurred when aai-update"); + } callbackClient.sendPostCallback(aaiRequest.getCallbackUrl(), mockCallbackResponse); - return response; - }); + }).start(); response.setResult(ResponseEntity.accepted().build()); return response; @@ -151,14 +156,18 @@ public class CnfAdapterRest { logger.info("aai-delete called."); DeferredResult response = new DeferredResult<>(); - ForkJoinPool.commonPool().submit(() -> { + new Thread(() -> { logger.info("Processing aai delete"); // aaiService.aaiDelete(aaiRequest); AaiCallbackResponse mockCallbackResponse = new AaiCallbackResponse(); mockCallbackResponse.setCompletionStatus(AaiCallbackResponse.CompletionStatus.COMPLETED); + try { + Thread.sleep(10_000L); + } catch (InterruptedException e) { + logger.error("InterruptedException occurred when aai-delete"); + } callbackClient.sendPostCallback(aaiRequest.getCallbackUrl(), mockCallbackResponse); - return response; - }); + }).start(); response.setResult(ResponseEntity.accepted().build()); return response; @@ -171,7 +180,7 @@ public class CnfAdapterRest { logger.info("statusCheck called."); DeferredResult response = new DeferredResult<>(); - ForkJoinPool.commonPool().submit(() -> { + new Thread(() -> { logger.info("Processing healthCheck service"); StatusCheckResponse statusCheckResponse = null; try { @@ -183,7 +192,7 @@ public class CnfAdapterRest { return; } callbackClient.sendPostCallback(statusCheckRequest.getCallbackUrl(), statusCheckResponse); - }); + }).start(); response.setResult(ResponseEntity.accepted().build()); return response;