SonarQube fix try 1

Author: alhusseain

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

@@ -36,7 +36,7 @@
 public class MessageQueue {
 
   private final BlockingQueue<Message> blkQueue;
-  public final Object serviceExecutorWait = new Object();
+  public Object serviceExecutorWait =new Object();
 
   // Default constructor when called creates Blocking Queue object. 
   public MessageQueue() {
@@ -51,7 +51,9 @@ public void submitMsg(Message msg) {
     try {
       if (null != msg) {
         blkQueue.add(msg);
-        serviceExecutorWait.notify();
+        synchronized (serviceExecutorWait) {
+          serviceExecutorWait.notifyAll();
+        }
       }
     } catch (Exception e) {
       LOGGER.error(e.getMessage());

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

@@ -56,8 +56,8 @@ 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<>();
+  private static Map<String, Instant> sessionCreationTimes = new HashMap<>();
   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)
 
@@ -125,7 +125,7 @@ private static void sessionExpirationTask() {
    */
   public static void expirationTaskWake() {
     synchronized (sessionExpirationWait) {
-      sessionExpirationWait.notify();
+      sessionExpirationWait.notifyAll();
     }
   }
 

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

@@ -86,7 +86,7 @@ public void resumeMe() {
     LOGGER.info("Begin to resume BallThread");
 
     synchronized (lock) {
-      lock.notify();
+      lock.notifyAll();
     }
   }
 
@@ -97,7 +97,7 @@ public void stopMe() {
     this.isRunning = false;
     this.isSuspended = true;
     synchronized (lock) {
-      lock.notify();
+      lock.notifyAll();
     }
   }
 }