MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Log cause when queue processing hits max retries

This commit is contained in:
Chris Eager 2022-08-01 16:57:24 -05:00 committed by Chris Eager
parent 55df593561
commit 1175ff5867
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
service/src/main/java/org/whispersystems/textsecuregcm/websocket/WebSocketConnection.java
View File

@ -294,11 +294,12 @@ public class WebSocketConnection implements MessageAvailabilityListener, Displac
} }
} else { } else {
if (client.isOpen()) { if (client.isOpen()) {
logger.debug("Failed to clear queue", cause);
if (consecutiveRetries.incrementAndGet() > MAX_CONSECUTIVE_RETRIES) { if (consecutiveRetries.incrementAndGet() > MAX_CONSECUTIVE_RETRIES) {
logger.warn("Max consecutive retries exceeded", cause);
client.close(1011, "Failed to retrieve messages"); client.close(1011, "Failed to retrieve messages");
} else { } else {
logger.debug("Failed to clear queue", cause);
final List<Tag> tags = List.of(UserAgentTagUtil.getPlatformTag(client.getUserAgent())); final List<Tag> tags = List.of(UserAgentTagUtil.getPlatformTag(client.getUserAgent()));
Metrics.counter(QUEUE_DRAIN_RETRY_COUNTER_NAME, tags).increment(); Metrics.counter(QUEUE_DRAIN_RETRY_COUNTER_NAME, tags).increment();