+ public ResponseEntity<CreateE2EServiceInstanceResponse> callServiceActivationE2EService(String globalSubscriberId,
+ String serviceType, String serviceInstanceId, String operation) {
+ String url = new StringBuilder(activationE2ESoUrl).append(serviceInstanceId).append("/").append(operation).toString();
+ MSOE2EServiceActivationPayload msoE2EServiceActivationPayload = new MSOE2EServiceActivationPayload();
+ msoE2EServiceActivationPayload.setGlobalSubscriberId(globalSubscriberId);
+ msoE2EServiceActivationPayload.setServiceType(serviceType);
+
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug("Calling SO E2E Service Activation/Deactivation with url : " + url + " MSOE2EServiceActivationPayload : "
+ + msoE2EServiceActivationPayload.toString());
+ }
+
+ try {
+ ResponseEntity<MSOE2EServiceActivationReponse> activationResponse = restTemplate.exchange(url,
+ HttpMethod.POST, new HttpEntity<>(msoE2EServiceActivationPayload, buildRequestHeader()),
+ MSOE2EServiceActivationReponse.class);
+ CreateE2EServiceInstanceResponse dummyresponse = buildDummyResponse(serviceInstanceId,
+ activationResponse.getBody().getOperationId());
+
+ ResponseEntity<CreateE2EServiceInstanceResponse> response =
+ new ResponseEntity(dummyresponse, activationResponse.getStatusCode());
+ logE2EResponsePost(url, response);
+ return response;
+
+ } catch (BackendFunctionalException e) {
+ LOGGER.error(ERROR_ON_CALLING + url + " ," + e);
+ return new ResponseEntity<>(e.getHttpStatus());
+ } catch (ResourceAccessException e) {
+ LOGGER.error(ERROR_ON_CALLING + url + " ," + e);
+ return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
+ }