fixup: gemini suggestion

Signed-off-by: Simon Schrottner <simon.schrottner@dynatrace.com>

Author: aepfli

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java

@@ -69,11 +69,7 @@ public SyncStreamQueueSource(final FlagdOptions options, Consumer<FlagdProviderE
                 FlagSyncServiceGrpc.newStub(channelConnector.getChannel()).withWaitForReady();
         metadataStub = FlagSyncServiceGrpc.newBlockingStub(channelConnector.getChannel())
                 .withWaitForReady();
-        scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
-            Thread t = new Thread(r, "flagd-sync-retry-scheduler");
-            t.setDaemon(true);
-            return t;
-        });
+        scheduler = createScheduler();
     }
 
     // internal use only
@@ -91,7 +87,11 @@ protected SyncStreamQueueSource(
         flagSyncStub = stubMock;
         syncMetadataDisabled = options.isSyncMetadataDisabled();
         metadataStub = blockingStubMock;
-        scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
+        scheduler = createScheduler();
+    }
+
+    private static ScheduledExecutorService createScheduler() {
+        return Executors.newSingleThreadScheduledExecutor(r -> {
             Thread t = new Thread(r, "flagd-sync-retry-scheduler");
             t.setDaemon(true);
             return t;
@@ -178,7 +178,7 @@ private void observeSyncStream() {
      */
     private void scheduleRetry() {
         if (shutdown.get()) {
-            log.info("Shutdown invoked, exiting event stream listener");
+            log.debug("Shutdown in progress, not scheduling retry.");
             return;
         }
         try {