fixup: gemini suggestion

Signed-off-by: Simon Schrottner <[email protected]>

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,13 +87,17 @@ protected SyncStreamQueueSource(
         flagSyncStub = stubMock;
         syncMetadataDisabled = options.isSyncMetadataDisabled();
         metadataStub = blockingStubMock;
-        scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
-            Thread t = new Thread(r, "flagd-sync-retry-scheduler");
-            t.setDaemon(true);
-            return t;
-        });
+        scheduler = createScheduler();
     }
 
+    private static ScheduledExecutorService createScheduler() {  
+        return Executors.newSingleThreadScheduledExecutor(r -> {  
+            Thread t = new Thread(r, "flagd-sync-retry-scheduler");  
+            t.setDaemon(true);  
+            return t;  
+        });  
+    }  
+
     /** Initialize sync stream connector. */
     public void init() throws Exception {
         channelConnector.initialize();
@@ -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 {