Unnecessary log removal (#2208)
[helix.git] / recipes / rabbitmq-consumer-group / src / main / java / org / apache / helix / recipes / rabbitmq / StartClusterManager.java
index 54c0ce09c1aa4cc9835310a975f30f668808574c..b8f6fa1b74d23776020644f1d405bd5d59da8969 100644 (file)
@@ -9,7 +9,7 @@ package org.apache.helix.recipes.rabbitmq;
  * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
- *   http://www.apache.org/licenses/LICENSE-2.0
+ *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
@@ -22,38 +22,31 @@ package org.apache.helix.recipes.rabbitmq;
 import org.apache.helix.HelixManager;
 import org.apache.helix.controller.HelixControllerMain;
 
-public class StartClusterManager
-{
-  public static void main(String[] args)
-  {
-    if (args.length < 1)
-    {
+public class StartClusterManager {
+  public static void main(String[] args) {
+    if (args.length < 1) {
       System.err.println("USAGE: java StartClusterManager zookeeperAddress (e.g. localhost:2181)");
       System.exit(1);
     }
-    
+
     final String clusterName = SetupConsumerCluster.DEFAULT_CLUSTER_NAME;
     final String zkAddr = args[0];
-    
-    try
-    {
-      final HelixManager manager = HelixControllerMain.startHelixController(zkAddr, clusterName, null,
-                                                        HelixControllerMain.STANDALONE);
-      
-      Runtime.getRuntime().addShutdownHook(new Thread()
-      {
+
+    try {
+      final HelixManager manager =
+          HelixControllerMain.startHelixController(zkAddr, clusterName, null,
+              HelixControllerMain.STANDALONE);
+
+      Runtime.getRuntime().addShutdownHook(new Thread() {
         @Override
-        public void run()
-        {
+        public void run() {
           System.out.println("Shutting down cluster manager: " + manager.getInstanceName());
           manager.disconnect();
         }
       });
-      
+
       Thread.currentThread().join();
-    }
-    catch (Exception e)
-    {
+    } catch (Exception e) {
       // TODO Auto-generated catch block
       e.printStackTrace();
     }