Pr comments

provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/WksServiceApplication.java

@@ -19,17 +19,12 @@ import org.springframework.web.client.RestTemplate;
 })
 public class WksServiceApplication {
 
-    private final static Logger LOGGER = LoggerFactory.getLogger(SchemaService.class);
+    private final static Logger LOGGER = LoggerFactory.getLogger(WksServiceApplication.class);
     public static void main(String[] args) {
         ApplicationContext context = SpringApplication.run(org.opengroup.osdu.wks.WksServiceApplication.class, args);
-        try {
-            SubscriptionManager subscriptionManager = context.getBean(SubscriptionManager.class);
-            subscriptionManager.subscribeRecordsChangeEvent();
-        }
-        catch (Exception e)
-        {
-            LOGGER.error(e.getMessage(), e);
-        }
+
+        SubscriptionManager subscriptionManager = context.getBean(SubscriptionManager.class);
+        subscriptionManager.subscribeRecordsChangeEvent();
     }
 
     @Bean("restTemplate")

provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/credentials/JwtTokenGenerator.java

@@ -39,7 +39,7 @@ public class JwtTokenGenerator implements UserCredential {
         }
 
         catch (UnsupportedEncodingException e) {
-            LOGGER.error(e.getMessage(), e);
+            LOGGER.warn(e.getMessage(), e);
             throw new ApplicationException(e.getMessage(), e.getCause());
         }
 

provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/pubsub/ProcessWKSTransform.java

@@ -66,16 +66,16 @@ public class ProcessWKSTransform {
             transformationSucceeded = true;
 
         } catch (BadRequestException e) {
-            LOGGER.error("Bad Request Reason: {}, pubsub message id: {}", e.getErrorMsg(),
+            LOGGER.warn("Bad Request Reason: {}, pubsub message id: {}", e.getErrorMsg(),
                     message.getMessageId(), e);
         } catch (ApplicationException e) {
-            LOGGER.error("Application Error Reason: {}, pubsub message id: {}", e.getErrorMsg(),
+            LOGGER.warn("Application Error Reason: {}, pubsub message id: {}", e.getErrorMsg(),
                     message.getMessageId(), e);
         } catch (NullPointerException e) {
-            LOGGER.error("Invalid format for message with id: {}", message.getMessageId(), e);
+            LOGGER.warn("Invalid format for message with id: {}", message.getMessageId(), e);
         }
         catch (Exception e) {
-            LOGGER.error("Exception encountered processing the message with id: {}", message.getMessageId(), e);
+            LOGGER.warn("Exception encountered processing the message with id: {}", message.getMessageId(), e);
         }
 
         if(!transformationSucceeded) {

provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/statusstore/StatusStoreServiceImpl.java

@@ -38,7 +38,7 @@ public class StatusStoreServiceImpl implements StatusStoreService {
                 cosmosStore.upsertItem(requestIdentity.getDataPartitionId(), cosmosContainerConfig.getDatabase(), cosmosContainerConfig.getRelationshipStatusContainer(), doc.getId(), doc);
             }
             catch (AppException exception) {
-                LOGGER.error("Status update failed for Record ID: {} and Mapping ID: {} with exception {}", relationshipStatus.getRawRecordId(), relationshipStatus.getMappingId(), exception.getError().getMessage(), exception);
+                LOGGER.warn("Status update failed for Record ID: {} and Mapping ID: {} with exception {}", relationshipStatus.getRawRecordId(), relationshipStatus.getMappingId(), exception.getError().getMessage(), exception);
             }
         }
     }

provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/storage/MappingStoreImpl.java

@@ -81,7 +81,7 @@ public class MappingStoreImpl implements MappingStore {
 
                 mappingsList.add(mapper.readValue(content, MappingsModel.class));
             } catch (Exception e) {
-                LOGGER.error("Error while processing mappings from blob store {}", e.getMessage(), e);
+                LOGGER.warn("Error while processing mappings from blob store {}", e.getMessage(), e);
             }
         }
         return mappingsList;

wks-core/src/main/java/org/opengroup/osdu/wks/WksServiceApplication.java

@@ -19,7 +19,7 @@ import org.springframework.web.client.RestTemplate;
 })
 public class WksServiceApplication {
 
-	private final static Logger LOGGER = LoggerFactory.getLogger(SchemaService.class);
+	private final static Logger LOGGER = LoggerFactory.getLogger(WksServiceApplication.class);
 	public static void main(String[] args) {
 		ApplicationContext context = SpringApplication.run(WksServiceApplication.class, args);
 		try {

wks-core/src/main/java/org/opengroup/osdu/wks/service/WKSServiceImpl.java

@@ -159,7 +159,7 @@ public class WKSServiceImpl implements WKSService {
                 LOGGER.warn(Constants.TRANFORMATION_FAILED, rawRecord.getId(), e.getErrorMsg(), e);
             }
             catch (Exception e) {
-                LOGGER.info(Constants.TRANFORMATION_FAILED, rawRecord.getId(), e.getMessage(), e);
+                LOGGER.warn(Constants.TRANFORMATION_FAILED, rawRecord.getId(), e.getMessage(), e);
             }
         }
 

wks-core/src/main/java/org/opengroup/osdu/wks/util/RelationshipBlockHandler.java

@@ -107,7 +107,7 @@ public class RelationshipBlockHandler {
             try {
                 wksRelationship = getRelationshipBlockWithWksIds(rawRelationship);
             } catch (ApplicationException e) {
-                LOGGER.info(e.getMessage(), e);
+                LOGGER.warn(e.getMessage(), e);
             }
             if(wksRelationship != null) {
                 wksRelationships.add(wksRelationship);
@@ -143,7 +143,7 @@ public class RelationshipBlockHandler {
             LOGGER.info("Querying search service for records having {} in ancestry", rawId);
             searchResults = searchService.query(searchRequestPayload.getJsonString());
         } catch(ApplicationException e) {
-            LOGGER.info("WKS not found from search service", e);
+            LOGGER.warn("WKS not found from search service", e);
         }
 
         Kind rawKind = new Kind(JsonTreeUtil.toTree(rawRecordJson).get("kind").asString());