diff --git a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/common/ChannelMonitor.java b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/common/ChannelMonitor.java index 7e27da34b..09edad8d5 100644 --- a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/common/ChannelMonitor.java +++ b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/common/ChannelMonitor.java @@ -48,7 +48,7 @@ public static void monitorChannelState( } } if (currentState != ConnectivityState.SHUTDOWN) { - log.debug("shutting down grpc channel"); + log.debug("continuing to monitor the grpc channel"); // Re-register the state monitor to watch for the next state transition. monitorChannelState(currentState, channel, onConnectionReady, onConnectionLost); } diff --git a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/grpc/GrpcStreamConnector.java b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/grpc/GrpcStreamConnector.java index e76ebfb24..2b359d236 100644 --- a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/grpc/GrpcStreamConnector.java +++ b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/grpc/GrpcStreamConnector.java @@ -116,6 +116,7 @@ void observeEventStream(final BlockingQueue writeTo, final AtomicB // instead of logging and throwing here, retain the exception and handle in the // stream logic below metadataException = e; + log.debug("Metadata exception: {}", e.getMessage(), e); } while (!shutdown.get()) { @@ -129,7 +130,10 @@ void observeEventStream(final BlockingQueue writeTo, final AtomicB Throwable streamException = response.getError(); if (streamException != null || metadataException != null) { - log.debug("Exception in GRPC connection"); + log.debug( + "Exception in GRPC connection, streamException {}, metadataException {}", + streamException, + metadataException); if (!writeTo.offer(new QueuePayload( QueuePayloadType.ERROR, "Error from stream or metadata", metadataResponse))) { log.error("Failed to convey ERROR status, queue is full");