polishing mvn format with mvn spottless apply

Author: harsh543

microservices-log-aggregation/src/main/java/com/iluwatar/logaggregation/LogAggregator.java

@@ -23,6 +23,7 @@
  * THE SOFTWARE.
  */
 package com.iluwatar.logaggregation;
+
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.BlockingQueue;
@@ -33,6 +34,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import lombok.extern.slf4j.Slf4j;
+
 /**
  * Responsible for collecting and buffering logs from different services. Once the logs reach a
  * certain threshold or after a certain time interval, they are flushed to the central log store.
@@ -206,8 +208,7 @@ private void startPeriodicFlusher() {
         FLUSH_INTERVAL_SECONDS, // Period
         TimeUnit.SECONDS);
 
-    LOGGER.info(
-        "Periodic log flusher started with interval of {} seconds", FLUSH_INTERVAL_SECONDS);
+    LOGGER.info("Periodic log flusher started with interval of {} seconds", FLUSH_INTERVAL_SECONDS);
   }
 
   /**

microservices-log-aggregation/src/test/java/com/iluwatar/logaggregation/LogAggregatorTest.java

@@ -195,4 +195,4 @@ private void verifyNoInteractionsWithCentralLogStore() {
   private void verifyCentralLogStoreInvokedTimes(int times) {
     verify(centralLogStore, times(times)).storeLog(any());
   }
-}
+}

server-session/src/main/java/com/iluwatar/sessionserver/App.java

@@ -24,19 +24,16 @@
  */
 package com.iluwatar.sessionserver;
 
-
-import java.util.HashMap;
 import com.sun.net.httpserver.HttpServer;
 import java.io.IOException;
 import java.net.InetSocketAddress;
-import java.util.Iterator;
 import java.time.Instant;
-import java.util.concurrent.ConcurrentHashMap;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.CountDownLatch;
-import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
 
 /**
@@ -68,7 +65,6 @@ public class App {
   private static volatile boolean running = true;
   private static final CountDownLatch shutdownLatch = new CountDownLatch(1);
 
-
   /**
    * Main entry point.
    *
@@ -106,33 +102,36 @@ private static void sessionExpirationTask() {
     try {
       LOGGER.info("Session expiration checker started...");
       Instant currentTime = Instant.now();
-      
+
       // Use removeIf for efficient removal without explicit synchronization
       // ConcurrentHashMap handles thread safety internally
-      sessionCreationTimes.entrySet().removeIf(entry -> {
-        if (entry.getValue().plusMillis(SESSION_EXPIRATION_TIME).isBefore(currentTime)) {
-          sessions.remove(entry.getKey());
-          LOGGER.debug("Expired session: {}", entry.getKey());
-          return true;
-        }
-        return false;
-      });
-      
+      sessionCreationTimes
+          .entrySet()
+          .removeIf(
+              entry -> {
+                if (entry.getValue().plusMillis(SESSION_EXPIRATION_TIME).isBefore(currentTime)) {
+                  sessions.remove(entry.getKey());
+                  LOGGER.debug("Expired session: {}", entry.getKey());
+                  return true;
+                }
+                return false;
+              });
+
       LOGGER.info("Session expiration checker finished! Active sessions: {}", sessions.size());
     } catch (Exception e) {
       LOGGER.error("An error occurred during session expiration check: ", e);
     }
   }
 
-   /**
-   * Gracefully shuts down the session expiration scheduler.
-   * This method is called by the shutdown hook.
+  /**
+   * Gracefully shuts down the session expiration scheduler. This method is called by the shutdown
+   * hook.
    */
   private static void shutdown() {
     LOGGER.info("Shutting down session expiration scheduler...");
     running = false;
     scheduler.shutdown();
-    
+
     try {
       if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) {
         LOGGER.warn("Scheduler did not terminate gracefully, forcing shutdown");
@@ -143,7 +142,7 @@ private static void shutdown() {
       scheduler.shutdownNow();
       Thread.currentThread().interrupt();
     }
-    
+
     shutdownLatch.countDown();
     LOGGER.info("Session expiration scheduler shut down complete");
   }

server-session/src/test/java/com/iluwatar/sessionserver/LoginHandlerTest.java

@@ -24,11 +24,6 @@
  */
 package com.iluwatar.logaggregation;
 
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-
-import java.time.LocalDateTime;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
@@ -44,6 +39,7 @@ public class LoginHandlerTest {
   private Map<String, Instant> sessionCreationTimes;
 
   @Mock private HttpExchange exchange;
+
   /** Setup tests. */
   @BeforeEach
   public void setUp() {