Skip to content
Snippets Groups Projects

Add latency metric for notification service

Merged Vasyl Leskiv [SLB] requested to merge vl/LatencyMetric into master
Files
14
@@ -74,7 +74,7 @@ public class PubsubEndpoint {
String notificationId = this.pubsubRequestBodyExtractor.extractNotificationIdFromRequestBody();
String pubsubMessage = this.pubsubRequestBodyExtractor.extractDataFromRequestBody();
Map<String, String> headerAttributes = this.pubsubRequestBodyExtractor.extractAttributesFromRequestBody();
HttpResponse response = notificationHandler.notifySubscriber(notificationId, pubsubMessage, headerAttributes);
HttpResponse response = notificationHandler.notifySubscriber(notificationId, pubsubMessage, headerAttributes, true);
if (!response.isSuccessCode()) {
this.log.error(NOT_ACKNOWLEDGE + response.getBody());
return new ResponseEntity<String>(NOT_ACKNOWLEDGE, HttpStatus.valueOf(response.getResponseCode()));
Loading