From 1175ff58672eb06765058d79ca1391570f1ac207 Mon Sep 17 00:00:00 2001
From: Chris Eager <chris@signal.org>
Date: Mon, 1 Aug 2022 16:57:24 -0500
Subject: [PATCH] Log cause when queue processing hits max retries

---
 .../textsecuregcm/websocket/WebSocketConnection.java           | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java b/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
index 431494ef3..8e3603c98 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
@@ -294,11 +294,12 @@ public class WebSocketConnection implements MessageAvailabilityListener, Displac
           }
         } else {
           if (client.isOpen()) {
-            logger.debug("Failed to clear queue", cause);
 
             if (consecutiveRetries.incrementAndGet() > MAX_CONSECUTIVE_RETRIES) {
+              logger.warn("Max consecutive retries exceeded", cause);
               client.close(1011, "Failed to retrieve messages");
             } else {
+              logger.debug("Failed to clear queue", cause);
               final List<Tag> tags = List.of(UserAgentTagUtil.getPlatformTag(client.getUserAgent()));
 
               Metrics.counter(QUEUE_DRAIN_RETRY_COUNTER_NAME, tags).increment();