Unnecessary log removal (#2208)
[helix.git] / recipes / rabbitmq-consumer-group / src / main / java / org / apache / helix / recipes / rabbitmq / StartClusterManager.java
index 5f43b53b181398818c7dda6b0508eee351938c44..b8f6fa1b74d23776020644f1d405bd5d59da8969 100644 (file)
@@ -1,40 +1,52 @@
 package org.apache.helix.recipes.rabbitmq;
 
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "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
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 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();
     }