Skip to content
Snippets Groups Projects
Commit fa57ebb7 authored by Sathyanarayanan Saravanamuthu's avatar Sathyanarayanan Saravanamuthu
Browse files

Resolving review comments

parent 33ee705a
No related branches found
No related tags found
3 merge requests!232Update os-core-lib-azure,!231initial commit,!181Adding entries to requests table on notification processing
Checking pipeline status
......@@ -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);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment