Replaced all tabs with spaces in java and pom.xml
[so.git] / adapters / mso-openstack-adapters / src / main / java / org / onap / so / adapters / audit / AbstractAuditService.java
index 710a6dd..52f5478 100644 (file)
@@ -1,7 +1,6 @@
 package org.onap.so.adapters.audit;
 
 import java.util.Optional;
-
 import org.camunda.bpm.client.task.ExternalTask;
 import org.onap.logging.ref.slf4j.ONAPLogConstants;
 import org.slf4j.Logger;
@@ -13,63 +12,64 @@ import org.springframework.stereotype.Component;
 
 @Component
 public abstract class AbstractAuditService {
-       
-       private static final Logger logger = LoggerFactory.getLogger(AbstractAuditService.class);
-       
-       
-       
-       protected static final String UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI = "Unable to find all VServers and L-Interaces in A&AI";
-       
-       @Autowired
-       public Environment env;
-       
-       /**
-        * @param auditHeatStackFailed
-        * @param auditList
-        * @return
-        */
-       protected boolean didCreateAuditFail(Optional<AAIObjectAuditList> auditList) {
-               if (auditList.get().getAuditList() != null && !auditList.get().getAuditList().isEmpty()) {
-                       if (logger.isInfoEnabled()) {
-                               logger.info("Audit Results: {}", auditList.get().toString());
-                       }
-                       return auditList.get().getAuditList().stream().filter(auditObject -> !auditObject.isDoesObjectExist())
-                                       .findFirst().map(v -> true).orElse(false);
-               } else {
-                       return false;
-               }
-       }
-       
-       /**
-        * @param auditHeatStackFailed
-        * @param auditList
-        * @return
-        */
-       protected boolean didDeleteAuditFail(Optional<AAIObjectAuditList> auditList) {
-               if (auditList.get().getAuditList() != null && !auditList.get().getAuditList().isEmpty()) {
-                       if (logger.isInfoEnabled()) {
-                               logger.info("Audit Results: {}", auditList.get().toString());
-                       }
-                       return auditList.get().getAuditList().stream().filter(AAIObjectAudit::isDoesObjectExist)
-                                       .findFirst().map(v -> true).orElse(false);
-               } else {
-                       return false;
-               }
-       }
-       
-       protected String[] getRetrySequence() {
-                return env.getProperty("mso.workflow.topics.retrySequence",String[].class);
-       }
-       
-       protected void setupMDC(ExternalTask externalTask) {
-               String msoRequestId = externalTask.getVariable("mso-request-id");
-               if(msoRequestId != null && !msoRequestId.isEmpty())
-                       MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, msoRequestId);
-       }
-       
-       protected long calculateRetryDelay(int currentRetries){
-               int retrySequence = getRetrySequence().length - currentRetries;
-               long retryMultiplier = Long.parseLong(env.getProperty("mso.workflow.topics.retryMultiplier","6000"));
-               return Integer.parseInt(getRetrySequence()[retrySequence]) * retryMultiplier;
-       }
+
+    private static final Logger logger = LoggerFactory.getLogger(AbstractAuditService.class);
+
+
+
+    protected static final String UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI =
+            "Unable to find all VServers and L-Interaces in A&AI";
+
+    @Autowired
+    public Environment env;
+
+    /**
+     * @param auditHeatStackFailed
+     * @param auditList
+     * @return
+     */
+    protected boolean didCreateAuditFail(Optional<AAIObjectAuditList> auditList) {
+        if (auditList.get().getAuditList() != null && !auditList.get().getAuditList().isEmpty()) {
+            if (logger.isInfoEnabled()) {
+                logger.info("Audit Results: {}", auditList.get().toString());
+            }
+            return auditList.get().getAuditList().stream().filter(auditObject -> !auditObject.isDoesObjectExist())
+                    .findFirst().map(v -> true).orElse(false);
+        } else {
+            return false;
+        }
+    }
+
+    /**
+     * @param auditHeatStackFailed
+     * @param auditList
+     * @return
+     */
+    protected boolean didDeleteAuditFail(Optional<AAIObjectAuditList> auditList) {
+        if (auditList.get().getAuditList() != null && !auditList.get().getAuditList().isEmpty()) {
+            if (logger.isInfoEnabled()) {
+                logger.info("Audit Results: {}", auditList.get().toString());
+            }
+            return auditList.get().getAuditList().stream().filter(AAIObjectAudit::isDoesObjectExist).findFirst()
+                    .map(v -> true).orElse(false);
+        } else {
+            return false;
+        }
+    }
+
+    protected String[] getRetrySequence() {
+        return env.getProperty("mso.workflow.topics.retrySequence", String[].class);
+    }
+
+    protected void setupMDC(ExternalTask externalTask) {
+        String msoRequestId = externalTask.getVariable("mso-request-id");
+        if (msoRequestId != null && !msoRequestId.isEmpty())
+            MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, msoRequestId);
+    }
+
+    protected long calculateRetryDelay(int currentRetries) {
+        int retrySequence = getRetrySequence().length - currentRetries;
+        long retryMultiplier = Long.parseLong(env.getProperty("mso.workflow.topics.retryMultiplier", "6000"));
+        return Integer.parseInt(getRetrySequence()[retrySequence]) * retryMultiplier;
+    }
 }