Replaced all tabs with spaces in java and pom.xml

[so.git] / common / src / main / java / org / onap / so / client / sdno / dmaap / SDNOHealthCheckDmaapConsumer.java

diff --git a/common/src/main/java/org/onap/so/client/sdno/dmaap/SDNOHealthCheckDmaapConsumer.java b/common/src/main/java/org/onap/so/client/sdno/dmaap/SDNOHealthCheckDmaapConsumer.java
index a76c47c..3589900 100644 (file)
--- a/common/src/main/java/org/onap/so/client/sdno/dmaap/SDNOHealthCheckDmaapConsumer.java
+++ b/common/src/main/java/org/onap/so/client/sdno/dmaap/SDNOHealthCheckDmaapConsumer.java
@@ -28,132 +28,137 @@ import org.onap.so.jsonpath.JsonPathUtil;
 
 public class SDNOHealthCheckDmaapConsumer extends DmaapConsumer {
 
-       private final String uuid;
-       private boolean continuePolling = true;
-       private final static String healthDiagnosticPath = "body.output.*";
-
-       public SDNOHealthCheckDmaapConsumer() throws IOException {
-               this("none");
-       }
-       
-       public SDNOHealthCheckDmaapConsumer(String uuid) throws IOException {
-               super();
-               this.uuid = uuid;
-       }
-       
-       @Override
-       public String getAuth() {
-               return msoProperties.get("sdno.health-check.dmaap.auth");
-       }
-
-       @Override
-       public String getKey() {
-               return msoProperties.get("mso.msoKey");
-       }
-
-       @Override
-       public String getTopic() {
-               return msoProperties.get("sdno.health-check.dmaap.subscriber.topic");
-       }
-       
-       @Override
-       public Optional<String> getHost() {
-               return Optional.ofNullable(msoProperties.get("sdno.health-check.dmaap.subscriber.host"));
-       }
-
-       @Override
-       public boolean continuePolling() {
-               return continuePolling;
-       }
-       
-       @Override
-       public void stopProcessingMessages() {
-               continuePolling = false;
-       }
-       @Override
-       public void processMessage(String message) throws Exception {
-               if (isHealthDiagnostic(message, this.getRequestId())) {
-                       if (!healthDiagnosticSuccessful(message)) {
-                               Optional<String> statusMessage = this.getStatusMessage(message);
-                               if (statusMessage.isPresent()) {
-                                       throw new SDNOException("failed with message " + statusMessage.get());
-                               } else {
-                                       throw new SDNOException("failed with no status message");
-                               }
-                       } else {
-                               logger.info("successful health diagnostic found for request: {}" ,getRequestId());
-                               stopProcessingMessages();
-                       }
-               }
-       }
-       
-       @Override
-       public boolean isAccepted(String message) {
-               if (isResultInfo(message)) {
-                       Optional<String> code = isAccepted(message, this.getRequestId());
-                       if (code.isPresent()) {
-                               if ("202".equals(code.get())) {
-                                       return true;
-                               } else {
-                                       //TODO check other statuses 400 and 500
-                               }
-                       } else {
-                               //TODO throw error
-                       }
-               }
-               
-               return false;
-       }
-       
-       @Override
-       public boolean isFailure(String message) {
-               if (isResultInfo(message)) {
-                       Optional<String> code = isFailure(message, this.getRequestId());
-                       if (code.isPresent()) {
-                               if ("500".equals(code.get())) {
-                                       return true;
-                               } else {
-                                       //TODO check other statuses 400 and 500
-                               }
-                       } else {
-                               //TODO throw error
-                       }
-               }
-               
-               return false;
-       }
-       
-       @Override
-       public String getRequestId() {
-               return uuid;
-       }
-       
-       protected Optional<String> isAccepted(String json, String uuid) {
-               return JsonPathUtil.getInstance().locateResult(json, String.format("$.result-info[?(@.status=='ACCEPTED' && @.request-id=='%s')].code", uuid));
-       }
-       
-       protected Optional<String> isFailure(String json, String uuid) {
-               return JsonPathUtil.getInstance().locateResult(json, String.format("$.result-info[?(@.status=='FAILURE' && @.request-id=='%s')].code", uuid));
-       }
-       
-       protected boolean isResultInfo(String json) {
-               return JsonPathUtil.getInstance().pathExists(json, "$[?(@.result-info)]");
-       }
-       
-       protected boolean isHealthDiagnostic(String json, String uuid) {
-               return JsonPathUtil.getInstance().pathExists(json, String.format("$[?(@.result-info.request-id=='%s')].%s", uuid, healthDiagnosticPath));
-       }
-       
-       protected boolean healthDiagnosticSuccessful(String json) {
-               return JsonPathUtil.getInstance().pathExists(json, "$." + healthDiagnosticPath + "[?(@.response-status=='Success')]");
-       }
-       
-       protected Optional<String> getStatusMessage(String json) {
-               return JsonPathUtil.getInstance().locateResult(json, "$." + healthDiagnosticPath + ".error-message");
-       }
-       
-       @Override
-       public int getMaximumElapsedTime() {
-               return 600000;
-       }
+    private final String uuid;
+    private boolean continuePolling = true;
+    private final static String healthDiagnosticPath = "body.output.*";
+
+    public SDNOHealthCheckDmaapConsumer() throws IOException {
+        this("none");
+    }
+
+    public SDNOHealthCheckDmaapConsumer(String uuid) throws IOException {
+        super();
+        this.uuid = uuid;
+    }
+
+    @Override
+    public String getAuth() {
+        return msoProperties.get("sdno.health-check.dmaap.auth");
+    }
+
+    @Override
+    public String getKey() {
+        return msoProperties.get("mso.msoKey");
+    }
+
+    @Override
+    public String getTopic() {
+        return msoProperties.get("sdno.health-check.dmaap.subscriber.topic");
+    }
+
+    @Override
+    public Optional<String> getHost() {
+        return Optional.ofNullable(msoProperties.get("sdno.health-check.dmaap.subscriber.host"));
+    }
+
+    @Override
+    public boolean continuePolling() {
+        return continuePolling;
+    }
+
+    @Override
+    public void stopProcessingMessages() {
+        continuePolling = false;
+    }
+
+    @Override
+    public void processMessage(String message) throws Exception {
+        if (isHealthDiagnostic(message, this.getRequestId())) {
+            if (!healthDiagnosticSuccessful(message)) {
+                Optional<String> statusMessage = this.getStatusMessage(message);
+                if (statusMessage.isPresent()) {
+                    throw new SDNOException("failed with message " + statusMessage.get());
+                } else {
+                    throw new SDNOException("failed with no status message");
+                }
+            } else {
+                logger.info("successful health diagnostic found for request: {}", getRequestId());
+                stopProcessingMessages();
+            }
+        }
+    }
+
+    @Override
+    public boolean isAccepted(String message) {
+        if (isResultInfo(message)) {
+            Optional<String> code = isAccepted(message, this.getRequestId());
+            if (code.isPresent()) {
+                if ("202".equals(code.get())) {
+                    return true;
+                } else {
+                    // TODO check other statuses 400 and 500
+                }
+            } else {
+                // TODO throw error
+            }
+        }
+
+        return false;
+    }
+
+    @Override
+    public boolean isFailure(String message) {
+        if (isResultInfo(message)) {
+            Optional<String> code = isFailure(message, this.getRequestId());
+            if (code.isPresent()) {
+                if ("500".equals(code.get())) {
+                    return true;
+                } else {
+                    // TODO check other statuses 400 and 500
+                }
+            } else {
+                // TODO throw error
+            }
+        }
+
+        return false;
+    }
+
+    @Override
+    public String getRequestId() {
+        return uuid;
+    }
+
+    protected Optional<String> isAccepted(String json, String uuid) {
+        return JsonPathUtil.getInstance().locateResult(json,
+                String.format("$.result-info[?(@.status=='ACCEPTED' && @.request-id=='%s')].code", uuid));
+    }
+
+    protected Optional<String> isFailure(String json, String uuid) {
+        return JsonPathUtil.getInstance().locateResult(json,
+                String.format("$.result-info[?(@.status=='FAILURE' && @.request-id=='%s')].code", uuid));
+    }
+
+    protected boolean isResultInfo(String json) {
+        return JsonPathUtil.getInstance().pathExists(json, "$[?(@.result-info)]");
+    }
+
+    protected boolean isHealthDiagnostic(String json, String uuid) {
+        return JsonPathUtil.getInstance().pathExists(json,
+                String.format("$[?(@.result-info.request-id=='%s')].%s", uuid, healthDiagnosticPath));
+    }
+
+    protected boolean healthDiagnosticSuccessful(String json) {
+        return JsonPathUtil.getInstance().pathExists(json,
+                "$." + healthDiagnosticPath + "[?(@.response-status=='Success')]");
+    }
+
+    protected Optional<String> getStatusMessage(String json) {
+        return JsonPathUtil.getInstance().locateResult(json, "$." + healthDiagnosticPath + ".error-message");
+    }
+
+    @Override
+    public int getMaximumElapsedTime() {
+        return 600000;
+    }
 }