X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=bpmn%2FMSOCommonBPMN%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fso%2Fbpmn%2Fappc%2Fpayload%2FPayloadClient.java;h=3b768cbc3ba2a97a533d0ac8041b61bd3527926b;hb=f47919f1fe367b612fa9c96d34c59f01a541e882;hp=45bc27d840edbef87b1e12f63537ad1aca2be0be;hpb=54452b80a1cf4d22ef750bc1377f8c1b05431d57;p=so.git

diff --git a/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/appc/payload/PayloadClient.java b/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/appc/payload/PayloadClient.java
index 45bc27d840..3b768cbc3b 100644
--- a/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/appc/payload/PayloadClient.java
+++ b/bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/appc/payload/PayloadClient.java
@@ -21,7 +21,6 @@
 package org.onap.so.bpmn.appc.payload;
 
 import java.util.Optional;
-
 import org.onap.so.bpmn.appc.payload.beans.ConfigurationParametersHealthCheck;
 import org.onap.so.bpmn.appc.payload.beans.ConfigurationParametersQuiesce;
 import org.onap.so.bpmn.appc.payload.beans.ConfigurationParametersResumeTraffic;
@@ -34,67 +33,69 @@ import org.onap.so.bpmn.appc.payload.beans.SnapshotAction;
 import org.onap.so.bpmn.appc.payload.beans.StartStopAction;
 import org.onap.so.bpmn.appc.payload.beans.UpgradeAction;
 import org.onap.so.bpmn.core.json.JsonUtils;
-
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
 public class PayloadClient {
 
-	protected static ObjectMapper mapper = new ObjectMapper();
-	
-	private PayloadClient() {}
-	
-	public static Optional<String> upgradeFormat(Optional<String> payload, String vnfName) throws JsonProcessingException{
-			UpgradeAction payloadResult = new UpgradeAction();
-			ConfigurationParametersUpgrade configParams = new ConfigurationParametersUpgrade();
-		    String payloadString = payload.isPresent() ? payload.get() : "";
-			String existingSoftware = JsonUtils.getJsonValue(payloadString, "existing_software_version");
-			String newSoftware = JsonUtils.getJsonValue(payloadString, "new_software_version");
-			configParams.setExistingSoftwareVersion(existingSoftware);
-			configParams.setNewSoftwareVersion(newSoftware);
-			configParams.setVnfName(vnfName);
-			payloadResult.setConfigurationParameters(configParams);
-			return Optional.of(mapper.writeValueAsString(payloadResult));
-	}
-	
-	public static Optional<String> resumeTrafficFormat(String vnfName) throws JsonProcessingException{
-			ResumeTrafficAction payloadResult = new ResumeTrafficAction();
-			ConfigurationParametersResumeTraffic configParams = new ConfigurationParametersResumeTraffic();
-			configParams.setVnfName(vnfName);
-			payloadResult.setConfigurationParameters(configParams);
-			return Optional.of(mapper.writeValueAsString(payloadResult));
-	} 
-	
-	public static Optional<String> quiesceTrafficFormat(Optional<String> payload, String vnfName) throws JsonProcessingException{
-			QuiesceTrafficAction payloadResult = new QuiesceTrafficAction();
-			ConfigurationParametersQuiesce configParams = new ConfigurationParametersQuiesce();
-			String payloadString = payload.isPresent() ? payload.get() : "";
-			String operationsTimeout = JsonUtils.getJsonValue(payloadString, "operations_timeout");
-			configParams.setOperationsTimeout(operationsTimeout);
-			configParams.setVnfName(vnfName);
-			payloadResult.setConfigurationParameters(configParams);
-			return Optional.of(mapper.writeValueAsString(payloadResult));
-	}
-	
-	public static Optional<String> startStopFormat(String aicIdentity) throws JsonProcessingException{
-			StartStopAction payloadResult = new StartStopAction();
-			payloadResult.setAicIdentity(aicIdentity);
-			return Optional.of(mapper.writeValueAsString(payloadResult));
-	}
-	
-	public static Optional<String> healthCheckFormat(String vnfName, String vnfHostIpAddress) throws JsonProcessingException{
-			HealthCheckAction payloadResult = new HealthCheckAction();
-			RequestParametersHealthCheck requestParams = new RequestParametersHealthCheck();
-			requestParams.setHostIpAddress(vnfHostIpAddress);
-			payloadResult.setRequestParameters(requestParams);
-			return Optional.of((mapper.writeValueAsString(payloadResult)));
-	}
-	
-	public static Optional<String> snapshotFormat(String vmId, String identityUrl)throws JsonProcessingException{
-			SnapshotAction payloadResult = new SnapshotAction();
-			payloadResult.setVmId(vmId);
-			payloadResult.setIdentityUrl(identityUrl);
-			return Optional.of(mapper.writeValueAsString(payloadResult));
-	}
-	
+    protected static ObjectMapper mapper = new ObjectMapper();
+
+    private PayloadClient() {}
+
+    public static Optional<String> upgradeFormat(Optional<String> payload, String vnfName)
+            throws JsonProcessingException {
+        UpgradeAction payloadResult = new UpgradeAction();
+        ConfigurationParametersUpgrade configParams = new ConfigurationParametersUpgrade();
+        String payloadString = payload.isPresent() ? payload.get() : "";
+        String existingSoftware = JsonUtils.getJsonValue(payloadString, "existing_software_version");
+        String newSoftware = JsonUtils.getJsonValue(payloadString, "new_software_version");
+        configParams.setExistingSoftwareVersion(existingSoftware);
+        configParams.setNewSoftwareVersion(newSoftware);
+        configParams.setVnfName(vnfName);
+        payloadResult.setConfigurationParameters(configParams);
+        return Optional.of(mapper.writeValueAsString(payloadResult));
+    }
+
+    public static Optional<String> resumeTrafficFormat(String vnfName) throws JsonProcessingException {
+        ResumeTrafficAction payloadResult = new ResumeTrafficAction();
+        ConfigurationParametersResumeTraffic configParams = new ConfigurationParametersResumeTraffic();
+        configParams.setVnfName(vnfName);
+        payloadResult.setConfigurationParameters(configParams);
+        return Optional.of(mapper.writeValueAsString(payloadResult));
+    }
+
+    public static Optional<String> quiesceTrafficFormat(Optional<String> payload, String vnfName)
+            throws JsonProcessingException {
+        QuiesceTrafficAction payloadResult = new QuiesceTrafficAction();
+        ConfigurationParametersQuiesce configParams = new ConfigurationParametersQuiesce();
+        String payloadString = payload.isPresent() ? payload.get() : "";
+        String operationsTimeout = JsonUtils.getJsonValue(payloadString, "operations_timeout");
+        configParams.setOperationsTimeout(operationsTimeout);
+        configParams.setVnfName(vnfName);
+        payloadResult.setConfigurationParameters(configParams);
+        return Optional.of(mapper.writeValueAsString(payloadResult));
+    }
+
+    public static Optional<String> startStopFormat(String aicIdentity) throws JsonProcessingException {
+        StartStopAction payloadResult = new StartStopAction();
+        payloadResult.setAicIdentity(aicIdentity);
+        return Optional.of(mapper.writeValueAsString(payloadResult));
+    }
+
+    public static Optional<String> healthCheckFormat(String vnfName, String vnfHostIpAddress)
+            throws JsonProcessingException {
+        HealthCheckAction payloadResult = new HealthCheckAction();
+        RequestParametersHealthCheck requestParams = new RequestParametersHealthCheck();
+        requestParams.setHostIpAddress(vnfHostIpAddress);
+        payloadResult.setRequestParameters(requestParams);
+        return Optional.of((mapper.writeValueAsString(payloadResult)));
+    }
+
+    public static Optional<String> snapshotFormat(String vmId, String identityUrl) throws JsonProcessingException {
+        SnapshotAction payloadResult = new SnapshotAction();
+        payloadResult.setVmId(vmId);
+        payloadResult.setIdentityUrl(identityUrl);
+        return Optional.of(mapper.writeValueAsString(payloadResult));
+    }
+
 }