Merge branch 'master' into addingBootstrappingJob

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

@@ -39,6 +39,8 @@ public class ProcessWKSTransform {
         try {
             RawRecordDetails[] rawRecordDetails = retrieveDataFromMessage(message);
             wKSService.transform(rawRecordDetails, dataPartitionId, correlationId);
+            
+            LOGGER.info("Transformation completed for message with id: " + message.getMessageId());
         } catch (BadRequestException e) {
             LOGGER.error("Bad Request Reason: {}, pubsub message id: {}", e.getErrorMsg(),
                     message.getMessageId());
@@ -51,6 +53,7 @@ public class ProcessWKSTransform {
     }
 
     private RawRecordDetails[] retrieveDataFromMessage(IMessage message) throws BadRequestException {
+        LOGGER.info("Transformation started for message with id: " + message.getMessageId());
         String messageData = new String(message.getMessageBody().getBinaryData().get(0), UTF_8);
 
         JsonElement jsonRoot = JsonParser.parseString(messageData);

provider/wks-azure/src/test/java/org/opengroup/osdu/wks/provider/azure/pubsub/ProcessWKSTransformTest.java

@@ -81,7 +81,7 @@ public class ProcessWKSTransformTest {
         verify(mdcContextMap, times(1)).getContextMap(correlationId, dataPartitionId);
         verify(message, times(2)).getProperties();
         verify(message, times(1)).getMessageBody();
-        verify(message, times(1)).getMessageId();
+        verify(message, times(2)).getMessageId();
     }
 
     @Test
@@ -94,7 +94,7 @@ public class ProcessWKSTransformTest {
         verify(mdcContextMap, times(1)).getContextMap(correlationId, dataPartitionId);
         verify(message, times(2)).getProperties();
         verify(message, times(1)).getMessageBody();
-        verify(message, times(1)).getMessageId();
+        verify(message, times(2)).getMessageId();
     }
 
     @Test
@@ -108,7 +108,7 @@ public class ProcessWKSTransformTest {
         verify(mdcContextMap, times(1)).getContextMap(correlationId, dataPartitionId);
         verify(message, times(2)).getProperties();
         verify(message, times(1)).getMessageBody();
-        verify(message, times(1)).getMessageId();
+        verify(message, times(2)).getMessageId();
     }
 
     @Test