Skip to content

Commit 05acb98

Browse files
authored
Merge branch 'main' into fix/fixing_missing_selector
2 parents 9fe354f + 34f83c5 commit 05acb98

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

Diff for: providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/common/ChannelMonitor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public static void monitorChannelState(
4848
}
4949
}
5050
if (currentState != ConnectivityState.SHUTDOWN) {
51-
log.debug("shutting down grpc channel");
51+
log.debug("continuing to monitor the grpc channel");
5252
// Re-register the state monitor to watch for the next state transition.
5353
monitorChannelState(currentState, channel, onConnectionReady, onConnectionLost);
5454
}

Diff for: providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/grpc/GrpcStreamConnector.java

+5-1
Original file line numberDiff line numberDiff line change
@@ -120,6 +120,7 @@ void observeEventStream(final BlockingQueue<QueuePayload> writeTo, final AtomicB
120120
// instead of logging and throwing here, retain the exception and handle in the
121121
// stream logic below
122122
metadataException = e;
123+
log.debug("Metadata exception: {}", e.getMessage(), e);
123124
}
124125

125126
while (!shutdown.get()) {
@@ -133,7 +134,10 @@ void observeEventStream(final BlockingQueue<QueuePayload> writeTo, final AtomicB
133134

134135
Throwable streamException = response.getError();
135136
if (streamException != null || metadataException != null) {
136-
log.debug("Exception in GRPC connection");
137+
log.debug(
138+
"Exception in GRPC connection, streamException {}, metadataException {}",
139+
streamException,
140+
metadataException);
137141
if (!writeTo.offer(new QueuePayload(
138142
QueuePayloadType.ERROR, "Error from stream or metadata", metadataResponse))) {
139143
log.error("Failed to convey ERROR status, queue is full");

0 commit comments

Comments
 (0)