Add consumer failed metric

uber-archive · May 18, 2017 · 7e98a04 · 7e98a04
1 parent 2a0a9ad
commit 7e98a04
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 0 deletions.
diff --git a/lib/src/main/java/com/uber/cherami/client/InputHostConnection.java b/lib/src/main/java/com/uber/cherami/client/InputHostConnection.java
@@ -449,6 +449,7 @@ public void run() {
             }
         } catch (Throwable throwable) {
             logger.error("InputHostConnection caught unexpected exception", throwable);
+            metricsReporter.report(Counter.PUBLISHER_MESSAGES_OUT_FAILED, 1L);
             stoppedLatch.countDown();
             close();
         } finally {

diff --git a/lib/src/main/java/com/uber/cherami/client/OutputHostConnection.java b/lib/src/main/java/com/uber/cherami/client/OutputHostConnection.java
@@ -435,6 +435,7 @@ public void run() {
                 }
             } catch (Throwable throwable) {
                 logger.error("ReadMessagesPump caught unexpected exception, remote={}", acknowledgerID, throwable);
+                metricsReporter.report(Counter.CONSUMER_MESSAGES_IN_FAILED, 1L);
                 closeAndNotify();
             }
         }

diff --git a/lib/src/main/java/com/uber/cherami/client/metrics/MetricsReporter.java b/lib/src/main/java/com/uber/cherami/client/metrics/MetricsReporter.java
@@ -111,6 +111,8 @@ public enum Counter {
         PUBLISHER_RECONFIGS("cherami.publish.reconfigure.rate"),
         /** Number of messages received by the consumer. */
         CONSUMER_MESSAGES_IN("cherami.consume.message.rate"),
+        /** Number of consume message attempts that failed or timed out */
+        CONSUMER_MESSAGES_IN_FAILED("cherami.consumer.message.failed"),
         /** Number of credits sent from the consumer to outputhosts. */
         CONSUMER_CREDITS_OUT("cherami.consume.credit.rate"),
         /** Number of credits that failed on send or timed out. */