diff --git a/src/main/kotlin/com/statsig/sdk/ErrorBoundary.kt b/src/main/kotlin/com/statsig/sdk/ErrorBoundary.kt index fe33f77..7b51013 100644 --- a/src/main/kotlin/com/statsig/sdk/ErrorBoundary.kt +++ b/src/main/kotlin/com/statsig/sdk/ErrorBoundary.kt @@ -134,8 +134,6 @@ internal class ErrorBoundary(private val apiKey: String, private val options: St throw ex } - options.customLogger.warning("[Statsig]: An unexpected exception occurred: $ex") - logException(tag, ex, configName) } diff --git a/src/main/kotlin/com/statsig/sdk/network/GRPCWebsocketWorker.kt b/src/main/kotlin/com/statsig/sdk/network/GRPCWebsocketWorker.kt index 5fae20a..4b97d59 100644 --- a/src/main/kotlin/com/statsig/sdk/network/GRPCWebsocketWorker.kt +++ b/src/main/kotlin/com/statsig/sdk/network/GRPCWebsocketWorker.kt @@ -133,11 +133,12 @@ internal class GRPCWebsocketWorker( streamingFallback?.startBackup(dcsFlowBacker) } if (shouldRetry) { + options.customLogger.warning("[Statsig]: grpcWebSocket: connection error: $throwable") errorBoundary.logException("grpcWebSocket: connection error", throwable ?: Exception("connection closed"), bypassDedupe = true) streamConfigSpecWithBackoff() connected = false } else { - options.customLogger.warning("failed to connect to forward proxy using gRPC streaming") + options.customLogger.warning("[Statsig]: grpcWebSocket: connection error: retry exhausted") errorBoundary.logException( "grpcWebSocket: retry exhausted", Exception("Remaining retry is $remainingRetries, exception is ${throwable?.message}"), @@ -162,6 +163,7 @@ internal class GRPCWebsocketWorker( if (response.lastUpdated >= lastUpdateTime) { lastUpdateTime = response.lastUpdated if (!dcsFlowBacker.tryEmit(response.spec)) { + options.customLogger.warning("[Statsig]: grpcWebSocket: Failed to emit response") errorBoundary.logException( "grpcWebSocket: Failed to emit response", Exception("${response.lastUpdated}"),