Unnecessary log removal (#2208)
[helix.git] / recipes / rabbitmq-consumer-group / src / main / java / org / apache / helix / recipes / rabbitmq / ConsumerThread.java
index d04850a727aa0b00348550ef759de751d157aada..f2a5a2e470e553a58f27942997bd0c84784826ef 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
@@ -26,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();
@@ -57,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();
         }