Updated checkstyle errors.

Chandana Amarnath · Chandana Amarnath · commit d6b5456f9884 · 2016-11-20T23:36:23.000+05:30
diff --git a/queue-load-leveling/src/main/java/org/queue/load/leveling/App.java b/queue-load-leveling/src/main/java/org/queue/load/leveling/App.java
@@ -71,25 +71,25 @@ public static void main(String[] args) {
       LOGGER.info("All the TaskGenerators started.");
       
       // Create three TaskGenerator threads. Each of them will submit different number of jobs.
-      Runnable taskRunnable_1 = new TaskGenerator(msgQueue, 5);
-      Runnable taskRunnable_2 = new TaskGenerator(msgQueue, 1);
-      Runnable taskRunnable_3 = new TaskGenerator(msgQueue, 2);
+      Runnable taskRunnable1 = new TaskGenerator(msgQueue, 5);
+      Runnable taskRunnable2 = new TaskGenerator(msgQueue, 1);
+      Runnable taskRunnable3 = new TaskGenerator(msgQueue, 2);
       
-      Thread taskGenerator_1 = new Thread(taskRunnable_1, "Task_Generator_1");
-      Thread taskGenerator_2 = new Thread(taskRunnable_2, "Task_Generator_2");
-      Thread taskGenerator_3 = new Thread(taskRunnable_3, "Task_Generator_3");
+      Thread taskGenerator1 = new Thread(taskRunnable1, "Task_Generator_1");
+      Thread taskGenerator2 = new Thread(taskRunnable2, "Task_Generator_2");
+      Thread taskGenerator3 = new Thread(taskRunnable3, "Task_Generator_3");
       
-      taskGenerator_1.start();
-      taskGenerator_2.start();
-      taskGenerator_3.start();
+      taskGenerator1.start();
+      taskGenerator2.start();
+      taskGenerator3.start();
       
       LOGGER.info("Service Executor started.");
       
       // First create e service which will process all the jobs.
       Runnable srvRunnable = new ServiceExecutor(msgQueue);
       Thread srvExec = new Thread(srvRunnable, "Service_Executor_Thread");
       srvExec.start();
-    } catch(Exception e) {
+    } catch (Exception e) {
       LOGGER.error(e.getMessage());
     }
   }
diff --git a/queue-load-leveling/src/main/java/org/queue/load/leveling/MessageQueue.java b/queue-load-leveling/src/main/java/org/queue/load/leveling/MessageQueue.java
@@ -48,14 +48,13 @@ public MessageQueue() {
   /**
    * All the TaskGenerator threads will call this method to insert the
    * Messages in to the Blocking Queue. 
-   * @param msg
    */
   public void submitMsg(Message msg) {
     try {
-      if(null != msg) {
+      if (null != msg) {
         blkQueue.add(msg);
       }
-    } catch(Exception e) {
+    } catch (Exception e) {
       LOGGER.error(e.getMessage());
     }
   }
@@ -68,8 +67,8 @@ public void submitMsg(Message msg) {
   public Message retrieveMsg() {
     Message retrievedMsg = null;
     try {
-       retrievedMsg = blkQueue.poll();
-    } catch(Exception e) {
+      retrievedMsg = blkQueue.poll();
+    } catch (Exception e) {
       LOGGER.error(e.getMessage());
     }
     
diff --git a/queue-load-leveling/src/main/java/org/queue/load/leveling/ServiceExecutor.java b/queue-load-leveling/src/main/java/org/queue/load/leveling/ServiceExecutor.java
@@ -47,20 +47,20 @@ public ServiceExecutor(MessageQueue msgQueue) {
    */
   public void run() {
     try {
-      while(true) {
+      while (true) {
         Message msg = msgQueue.retrieveMsg();
         
-        if(null != msg) {
+        if (null != msg) {
           LOGGER.info(msg.toString() + " is served.");
         } else {
           LOGGER.info("ServiceExecutor: All tasks are executed. Waiting.");
         }
         
         Thread.sleep(1000);
       }
-    } catch(InterruptedException ie) { 
+    } catch (InterruptedException ie) { 
       LOGGER.error(ie.getMessage());
-    } catch(Exception e) {
+    } catch (Exception e) {
       LOGGER.error(e.getMessage());
     }
   }
diff --git a/queue-load-leveling/src/main/java/org/queue/load/leveling/TaskGenerator.java b/queue-load-leveling/src/main/java/org/queue/load/leveling/TaskGenerator.java
@@ -54,7 +54,7 @@ public TaskGenerator(MessageQueue msgQueue, int msgCount) {
   public void submit(Message msg) {
     try {
       this.msgQueue.submitMsg(msg);
-    } catch(Exception e) {
+    } catch (Exception e) {
       LOGGER.error(e.getMessage());
     }
   }
@@ -65,7 +65,7 @@ public void submit(Message msg) {
    */
   public void run() {
     try {
-      while(this.msgCount > 0) {
+      while (this.msgCount > 0) {
         String statusMsg = "Message-" + this.msgCount + " submitted by " + Thread.currentThread().getName();
         Message newMessage = new Message(statusMsg);
         this.submit(newMessage);
@@ -78,9 +78,9 @@ public void run() {
         // Make the current thread to sleep after every Message submission.
         Thread.sleep(1000);
       }
-    } catch(InterruptedException ie) {
+    } catch (InterruptedException ie) {
       LOGGER.error(ie.getMessage());
-    } catch(Exception e) {
+    } catch (Exception e) {
       LOGGER.error(e.getMessage());
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -47,20 +47,20 @@ public ServiceExecutor(MessageQueue msgQueue) {`
`47`	`47`	`*/`
`48`	`48`	`public void run() {`
`49`	`49`	`try {`
`50`		`- while(true) {`
	`50`	`+ while (true) {`
`51`	`51`	`Message msg = msgQueue.retrieveMsg();`
`52`	`52`
`53`		`- if(null != msg) {`
	`53`	`+ if (null != msg) {`
`54`	`54`	`LOGGER.info(msg.toString() + " is served.");`
`55`	`55`	`} else {`
`56`	`56`	`LOGGER.info("ServiceExecutor: All tasks are executed. Waiting.");`
`57`	`57`	`}`
`58`	`58`
`59`	`59`	`Thread.sleep(1000);`
`60`	`60`	`}`
`61`		`- } catch(InterruptedException ie) {`
	`61`	`+ } catch (InterruptedException ie) {`
`62`	`62`	`LOGGER.error(ie.getMessage());`
`63`		`- } catch(Exception e) {`
	`63`	`+ } catch (Exception e) {`
`64`	`64`	`LOGGER.error(e.getMessage());`
`65`	`65`	`}`
`66`	`66`	`}`
Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ public TaskGenerator(MessageQueue msgQueue, int msgCount) {`
`54`	`54`	`public void submit(Message msg) {`
`55`	`55`	`try {`
`56`	`56`	`this.msgQueue.submitMsg(msg);`
`57`		`- } catch(Exception e) {`
	`57`	`+ } catch (Exception e) {`
`58`	`58`	`LOGGER.error(e.getMessage());`
`59`	`59`	`}`
`60`	`60`	`}`
`@@ -65,7 +65,7 @@ public void submit(Message msg) {`
`65`	`65`	`*/`
`66`	`66`	`public void run() {`
`67`	`67`	`try {`
`68`		`- while(this.msgCount > 0) {`
	`68`	`+ while (this.msgCount > 0) {`
`69`	`69`	`String statusMsg = "Message-" + this.msgCount + " submitted by " + Thread.currentThread().getName();`
`70`	`70`	`Message newMessage = new Message(statusMsg);`
`71`	`71`	`this.submit(newMessage);`
`@@ -78,9 +78,9 @@ public void run() {`
`78`	`78`	`// Make the current thread to sleep after every Message submission.`
`79`	`79`	`Thread.sleep(1000);`
`80`	`80`	`}`
`81`		`- } catch(InterruptedException ie) {`
	`81`	`+ } catch (InterruptedException ie) {`
`82`	`82`	`LOGGER.error(ie.getMessage());`
`83`		`- } catch(Exception e) {`
	`83`	`+ } catch (Exception e) {`
`84`	`84`	`LOGGER.error(e.getMessage());`
`85`	`85`	`}`
`86`	`86`	`}`