Unnecessary log removal (#2208)
[helix.git] / recipes / rabbitmq-consumer-group / src / main / java / org / apache / helix / recipes / rabbitmq / ConsumerThread.java
index 0a6ed5ca4b421c0ff833751c24c32c17a963338d..f2a5a2e470e553a58f27942997bd0c84784826ef 100644 (file)
@@ -1,5 +1,24 @@
 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 java.io.IOException;
 
 import com.rabbitmq.client.Channel;
@@ -7,26 +26,22 @@ import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.QueueingConsumer;
 
-public class ConsumerThread extends Thread
-{
+public class ConsumerThread extends Thread {
   private static final String EXCHANGE_NAME = "topic_logs";
   private final String _partition;
   private final String _mqServer;
   private final String _consumerId;
-  
-  public ConsumerThread(String partition, String mqServer, String consumerId)
-  {
+
+  public ConsumerThread(String partition, String mqServer, String consumerId) {
     _partition = partition;
     _mqServer = mqServer;
     _consumerId = consumerId;
   }
 
   @Override
-  public void run()
-  {
+  public void run() {
     Connection connection = null;
-    try
-    {
+    try {
       ConnectionFactory factory = new ConnectionFactory();
       factory.setHost(_mqServer);
       connection = factory.newConnection();
@@ -38,35 +53,29 @@ public class ConsumerThread extends Thread
       String bindingKey = _partition;
       channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);
 
-      System.out.println(" [*] " + _consumerId + " Waiting for messages on " + bindingKey + ". To exit press CTRL+C");
+      System.out.println(" [*] " + _consumerId + " Waiting for messages on " + bindingKey
+          + ". To exit press CTRL+C");
 
       QueueingConsumer consumer = new QueueingConsumer(channel);
       channel.basicConsume(queueName, true, consumer);
 
-      while (true)
-      {
+      while (true) {
         QueueingConsumer.Delivery delivery = consumer.nextDelivery();
         String message = new String(delivery.getBody());
         String routingKey = delivery.getEnvelope().getRoutingKey();
 
-        System.out.println(" [x] " + _consumerId + " Received '" + routingKey + "':'" + message + "'");
+        System.out.println(" [x] " + _consumerId + " Received '" + routingKey + "':'" + message
+            + "'");
       }
-    } catch (InterruptedException e)
-    {
+    } catch (InterruptedException e) {
       System.err.println(" [-] " + _consumerId + " on " + _partition + " is interrupted ...");
-    }
-    catch (Exception e)
-    {
+    } catch (Exception e) {
       e.printStackTrace();
-    } finally
-    {
-      if (connection != null)
-      {
-        try
-        {
+    } finally {
+      if (connection != null) {
+        try {
           connection.close();
-        } catch (IOException e)
-        {
+        } catch (IOException e) {
           // TODO Auto-generated catch block
           e.printStackTrace();
         }