From 284b2428e120d6a8d4c007dd0d5d5fa3cc9c4ce7 Mon Sep 17 00:00:00 2001
From: Sathyanarayanan Saravanamuthu <sasarava@microsoft.com>
Date: Thu, 3 Feb 2022 16:33:31 +0530
Subject: [PATCH] Adding entries to requests table on notification processing
---
.../azure/messageBus/ProcessNotification.java | 21 +++++++++++++++++++
1 file changed, 21 insertions(+)
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 e33e641f5..21b79cdc0 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
@@ -14,7 +14,10 @@
package org.opengroup.osdu.notification.provider.azure.messageBus;
+import com.microsoft.applicationinsights.TelemetryClient;
+import com.microsoft.applicationinsights.telemetry.RequestTelemetry;
import com.microsoft.azure.servicebus.IMessage;
+import org.apache.commons.lang3.time.StopWatch;
import org.opengroup.osdu.core.common.http.HttpResponse;
import org.opengroup.osdu.core.common.model.http.DpsHeaders;
import org.opengroup.osdu.notification.provider.azure.messageBus.thread.ThreadScopeContextHolder;
@@ -45,6 +48,10 @@ public class ProcessNotification {
private MDCContextMap mdcContextMap;
public void performNotification(IMessage message, String subscriptionName) throws Exception {
+ TelemetryClient telemetryClient = new TelemetryClient();
+ StopWatch stopWatch = new StopWatch();
+ stopWatch.start();
+
try {
NotificationContent notificationContent = requestBodyAdapter.extractNotificationContent(message, subscriptionName);
@@ -58,8 +65,22 @@ 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);
throw new Exception(NOT_ACKNOWLEDGE);
+ }else{
+ requestTelemetry.setResponseCode("200");
+ requestTelemetry.setSuccess(true);
+ telemetryClient.trackRequest(requestTelemetry);
}
} catch (Exception e) {
LOGGER.error(String.format("An error occurred performing Notification for message with ID: ", message.getMessageId()), e);
--
GitLab