fix lint issues

Signed-off-by: Konvalinka <[email protected]>

Author: leakonvalinka

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/FlagdOptions.java

@@ -129,7 +129,8 @@ public class FlagdOptions {
      * Defaults to empty list
      */
     @Builder.Default
-    private List<String> fatalStatusCodes = fallBackToEnvOrDefaultList(Config.FATAL_STATUS_CODES_ENV_VAR_NAME, List.of());
+    private List<String> fatalStatusCodes =
+            fallBackToEnvOrDefaultList(Config.FATAL_STATUS_CODES_ENV_VAR_NAME, List.of());
 
     /**
      * Selector to be used with flag sync gRPC contract.

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

@@ -195,8 +195,11 @@ private void observeSyncStream() {
                     observer.metadata = getMetadata();
                 } catch (StatusRuntimeException metaEx) {
                     if (fatalStatusCodes.contains(metaEx.getStatus().getCode().name()) && !successfulSync.get()) {
-                        log.debug("Fatal status code for metadata request: {}, not retrying", metaEx.getStatus().getCode());
-                        enqueueFatal(String.format("Fatal: Failed to connect for metadata request, not retrying for error %s", metaEx.getStatus().getCode()));
+                        log.debug("Fatal status code for metadata request: {}, not retrying",
+                                metaEx.getStatus().getCode());
+                        enqueueFatal(String.format(
+                                "Fatal: Failed to connect for metadata request, not retrying for error %s",
+                                metaEx.getStatus().getCode()));
                         return;
                     } else {
                         // retry for other status codes
@@ -214,7 +217,9 @@ private void observeSyncStream() {
                 } catch (StatusRuntimeException ex) {
                     if (fatalStatusCodes.contains(ex.getStatus().getCode().toString()) && !successfulSync.get()) {
                         log.debug("Fatal status code during sync stream: {}, not retrying", ex.getStatus().getCode());
-                        enqueueFatal(String.format("Fatal: Failed to connect for metadata request, not retrying for error %s", ex.getStatus().getCode()));
+                        enqueueFatal(String.format(
+                                "Fatal: Failed to connect for metadata request, not retrying for error %s",
+                                ex.getStatus().getCode()));
                         return;
                     } else {
                         // retry for other status codes
@@ -289,16 +294,16 @@ private void enqueueError(String message) {
         enqueueError(outgoingQueue, message);
     }
 
-    private void enqueueFatal(String message) {
-        enqueueFatal(outgoingQueue, message);
-    }
-
     private static void enqueueError(BlockingQueue<QueuePayload> queue, String message) {
         if (!queue.offer(new QueuePayload(QueuePayloadType.ERROR, message, null))) {
             log.error("Failed to convey ERROR status, queue is full");
         }
     }
 
+    private void enqueueFatal(String message) {
+        enqueueFatal(outgoingQueue, message);
+    }
+
     private static void enqueueFatal(BlockingQueue<QueuePayload> queue, String message) {
         if (!queue.offer(new QueuePayload(QueuePayloadType.FATAL, message, null))) {
             log.error("Failed to convey FATAL status, queue is full");
@@ -313,7 +318,8 @@ private static class SyncStreamObserver implements StreamObserver<SyncFlagsRespo
 
         private Struct metadata;
 
-        public SyncStreamObserver(BlockingQueue<QueuePayload> outgoingQueue, AtomicBoolean shouldThrottle, List<String> fatalStatusCodes) {
+        public SyncStreamObserver(BlockingQueue<QueuePayload> outgoingQueue, AtomicBoolean shouldThrottle,
+                List<String> fatalStatusCodes) {
             this.outgoingQueue = outgoingQueue;
             this.shouldThrottle = shouldThrottle;
             this.fatalStatusCodes = fatalStatusCodes;

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/rpc/RpcResolver.java

@@ -353,8 +353,10 @@ private void observeEventStream() throws InterruptedException {
                 Throwable streamException = taken.getError();
                 if (streamException != null) {
                     if (streamException instanceof StatusRuntimeException && fatalStatusCodes.contains(
-                            ((StatusRuntimeException) streamException).getStatus().getCode().name()) && !successfulConnection.get()) {
-                        log.debug("Fatal error code received: {}", ((StatusRuntimeException) streamException).getStatus().getCode());
+                            ((StatusRuntimeException) streamException).getStatus().getCode().name())
+                            && !successfulConnection.get()) {
+                        log.debug("Fatal error code received: {}",
+                                ((StatusRuntimeException) streamException).getStatus().getCode());
                         this.handleFatalError();
                     } else {
                         log.debug(