Log the error message when retrying queue send

This commit is contained in:
Fedor Indutny
2021-09-16 15:03:42 -07:00
committed by GitHub
parent c2ba8ab562
commit 383d744bd8

View File

@@ -258,6 +258,8 @@ public class WebSocketConnection implements MessageAvailabilityListener, Displac
processStoredMessages();
}
} else {
logger.debug("Failed to clear queue", cause);
if (consecutiveRetries.incrementAndGet() > MAX_CONSECUTIVE_RETRIES) {
client.close(1011, "Failed to retrieve messages");
} else {