Update SyncStreamQueueSource.java

toddbaert · web-flow · commit b21ff3e7b1fe · 2025-06-25T13:08:45.000-04:00
Signed-off-by: Todd Baert &lt;todd.baert@dynatrace.com&gt;
diff --git a/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java b/providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java
@@ -141,7 +141,8 @@ private void observeSyncStream() throws InterruptedException {
 
                         metadataResponse = localStub.getMetadata(metadataRequest.build());
                     } catch (Exception metaEx) {
-                        // cancel the stream if the getMetadata fails, but we can keep this log quiet since the stream is cancelled/restarted with this exception
+                        // cancel the stream if the getMetadata fails
+                        // we can keep this log quiet since the stream is cancelled/restarted with this exception
                         log.debug("Metadata exception: {}, cancelling stream", metaEx.getMessage(), metaEx);
                         context.cancel(metaEx);
                     }

Original file line number	Diff line number	Diff line change
`@@ -141,7 +141,8 @@ private void observeSyncStream() throws InterruptedException {`
`141`	`141`
`142`	`142`	`metadataResponse = localStub.getMetadata(metadataRequest.build());`
`143`	`143`	`} catch (Exception metaEx) {`
`144`		`- // cancel the stream if the getMetadata fails, but we can keep this log quiet since the stream is cancelled/restarted with this exception`
	`144`	`+ // cancel the stream if the getMetadata fails`
	`145`	`+ // we can keep this log quiet since the stream is cancelled/restarted with this exception`
`145`	`146`	`log.debug("Metadata exception: {}, cancelling stream", metaEx.getMessage(), metaEx);`
`146`	`147`	`context.cancel(metaEx);`
`147`	`148`	`}`