From 81e835239150787eb8645225504922e04c8082ea Mon Sep 17 00:00:00 2001
From: Jon Chambers <jon@signal.org>
Date: Wed, 25 Nov 2020 14:54:35 -0500
Subject: [PATCH] Time (and count) SQS "send message" operations.

---
 .../org/whispersystems/textsecuregcm/sqs/DirectoryQueue.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/sqs/DirectoryQueue.java b/service/src/main/java/org/whispersystems/textsecuregcm/sqs/DirectoryQueue.java
index 1137ab114..53a056982 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/sqs/DirectoryQueue.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/sqs/DirectoryQueue.java
@@ -16,6 +16,7 @@ import com.amazonaws.services.sqs.model.SendMessageRequest;
 import com.codahale.metrics.Meter;
 import com.codahale.metrics.MetricRegistry;
 import com.codahale.metrics.SharedMetricRegistries;
+import com.codahale.metrics.Timer;
 import com.google.common.annotations.VisibleForTesting;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -36,6 +37,7 @@ public class DirectoryQueue {
   private final MetricRegistry metricRegistry    = SharedMetricRegistries.getOrCreate(Constants.METRICS_NAME);
   private final Meter          serviceErrorMeter = metricRegistry.meter(name(DirectoryQueue.class, "serviceError"));
   private final Meter          clientErrorMeter  = metricRegistry.meter(name(DirectoryQueue.class, "clientError"));
+  private final Timer          sendMessageTimer  = metricRegistry.timer(name(DirectoryQueue.class, "sendMessage"));
 
   private final String         queueUrl;
   private final AmazonSQS      sqs;
@@ -73,7 +75,7 @@ public class DirectoryQueue {
             .withMessageDeduplicationId(UUID.randomUUID().toString())
             .withMessageGroupId(number)
             .withMessageAttributes(messageAttributes);
-    try {
+    try (final Timer.Context ignored = sendMessageTimer.time()) {
       sqs.sendMessage(sendMessageRequest);
     } catch (AmazonServiceException ex) {
       serviceErrorMeter.mark();