diff --git a/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/ProcessNotification.java b/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/ProcessNotification.java
index 20a0efee2de2072929bbab0df3b36271e1f5e37d..07ce2501d9e7c5a54676c08005c2d0d3cc502bb8 100644
--- a/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/ProcessNotification.java
+++ b/provider/notification-azure/src/main/java/org/opengroup/osdu/notification/provider/azure/messageBus/ProcessNotification.java
@@ -63,14 +63,6 @@ public class ProcessNotification {
             ConcurrentMap properties = telemetryClient.getContext().getProperties();
             properties.put("correlation-id",correlationId);
             properties.put("data-partition-id", dataPartitionId); 
-
-            RequestTelemetry requestTelemetry = new RequestTelemetry(
-                "SBQueueRequest",
-                new Date(),
-                stopWatch.getTime(),
-                "500",
-                false);
-            requestTelemetry.setId(message.getMessageId());
             
             MDC.setContextMap(mdcContextMap.getContextMap(correlationId, dataPartitionId));
             dpsHeaders.setThreadContext(dataPartitionId, correlationId);
@@ -79,6 +71,14 @@ public class ProcessNotification {
 
             HttpResponse response = notificationHandler.notifySubscriber(notificationContent.getNotificationId(),
                     notificationContent.getData(), notificationContent.getExtractAttributes());
+
+            RequestTelemetry requestTelemetry = new RequestTelemetry(
+                "SBQueueRequest",
+                new Date(),
+                stopWatch.getTime(),
+                "500",
+                false);
+            requestTelemetry.setId(message.getMessageId());                    
                                            
             if (!response.isSuccessCode()) {
                 telemetryClient.trackRequest(requestTelemetry);