Checkstyle fix try 2

Author: alhusseain

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

@@ -46,7 +46,7 @@ public class LogAggregator {
   private final ConcurrentLinkedQueue<LogEntry> buffer = new ConcurrentLinkedQueue<>();
   private final LogLevel minLogLevel;
   private final ExecutorService executorService = Executors.newSingleThreadExecutor();
-  private final Object bufferWait=new Object();
+  private final Object bufferWait = new Object();
   private final AtomicInteger logCount = new AtomicInteger(0);
 
   /**
@@ -124,9 +124,12 @@ private void startBufferFlusher() {
       }
     });
   }
-  public void bufferWake(){
-    synchronized (bufferWait)
-    {
+
+  /**
+   * Wakes up buffer.
+   */
+  public void bufferWake() {
+    synchronized (bufferWait) {
       bufferWait.notify();
     }
   }

queue-based-load-leveling/src/main/java/com/iluwatar/queue/load/leveling/ServiceExecutor.java

@@ -50,9 +50,8 @@ public void run() {
           LOGGER.info(msg + " is served.");
         } else {
           LOGGER.info("Service Executor: Waiting for Messages to serve .. ");
-          synchronized (msgQueue.serviceExecutorWait)
-          {
-              msgQueue.serviceExecutorWait.wait();
+          synchronized (msgQueue.serviceExecutorWait) {
+            msgQueue.serviceExecutorWait.wait();
           }
         }
       }

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

@@ -56,10 +56,10 @@ public class App {
 
   // Map to store session data (simulated using a HashMap)
 
-  private static Map<String, Integer> sessions = new HashMap<String,Integer>();
-  private static Map<String, Instant> sessionCreationTimes = new HashMap<String,Instant>();
+  private static Map<String, Integer> sessions = new HashMap<String, Integer>();
+  private static Map<String, Instant> sessionCreationTimes = new HashMap<String, Instant>();
   private static final long SESSION_EXPIRATION_TIME = 10000;
-  private static final Object sessionExpirationWait=new Object(); // used to make expiration task wait or work based on event (login request sent or not)
+  private static final Object sessionExpirationWait = new Object(); // used to make expiration task wait or work based on event (login request sent or not)
 
   /**
    * Main entry point.
@@ -84,16 +84,15 @@ public static void main(String[] args) throws IOException {
   }
 
   private static void sessionExpirationTask() {
-     new Thread(() -> {
+    new Thread(() -> {
       while (true) {
         try {
-          synchronized (sessions)
-          {
-              if(sessions.isEmpty())
-              synchronized (sessionExpirationWait)
-              {
-                sessionExpirationWait.wait(); // Make Session expiration Checker wait until at least a single login request is sent.
+          synchronized (sessions) {
+            if (sessions.isEmpty()) {
+              synchronized (sessionExpirationWait) {
+                sessionExpirationWait.wait();
               }
+            }
           }
           LOGGER.info("Session expiration checker started...");
           Thread.sleep(SESSION_EXPIRATION_TIME); // Sleep for expiration time
@@ -121,12 +120,13 @@ private static void sessionExpirationTask() {
     }).start();
   }
 
-  public static void expirationTaskWake() //Wake up sleeping Expiration task thread
-  {
-      synchronized (sessionExpirationWait)
-      {
-        sessionExpirationWait.notify();
-      }
+  /**
+   * allows sessionExpirationTask to run again, called when a login request is sent.
+   */
+  public static void expirationTaskWake() {
+    synchronized (sessionExpirationWait) {
+      sessionExpirationWait.notify();
     }
+  }
 
 }

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

@@ -42,6 +42,9 @@ public class LoginHandler implements HttpHandler {
   private Map<String, Integer> sessions;
   private Map<String, Instant> sessionCreationTimes;
 
+  /**
+   * Handles new login requests.
+   */
   public LoginHandler(Map<String, Integer> sessions, Map<String, Instant> sessionCreationTimes) {
     this.sessions = sessions;
     this.sessionCreationTimes = sessionCreationTimes;

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

@@ -41,6 +41,9 @@ public class LogoutHandler implements HttpHandler {
   private Map<String, Integer> sessions;
   private Map<String, Instant> sessionCreationTimes;
 
+  /**
+   * Handles logging out requests.
+   */
   public LogoutHandler(Map<String, Integer> sessions, Map<String, Instant> sessionCreationTimes) {
     this.sessions = sessions;
     this.sessionCreationTimes = sessionCreationTimes;

twin/src/main/java/com/iluwatar/twin/BallThread.java

@@ -53,7 +53,7 @@ public void run() {
       if (isSuspended) {
         synchronized (lock) {
           try {
-            lock.wait(); //Wait until resumed :: busy loop fix
+            lock.wait();
           } catch (InterruptedException e) {
             throw new RuntimeException(e);
           }
@@ -69,20 +69,30 @@ public void run() {
       }
     }
   }
-
+  /**
+   * suspend the thread.
+   */
   public void suspendMe() {
     isSuspended = true;
     LOGGER.info("Begin to suspend BallThread");
   }
 
+  /**
+   * notify run to resume.
+   */
+
   public void resumeMe() {
     isSuspended = false;
     LOGGER.info("Begin to resume BallThread");
+
     synchronized (lock) {
       lock.notify();
     }
   }
 
+  /**
+   * Stop running thread.
+   */
   public void stopMe() {
     this.isRunning = false;
     this.isSuspended = true;