1 files changed, 25 insertions, 26 deletions
diff --git a/sdc-distribution-client/src/main/java/org/onap/sdc/impl/StatusConsumer.java b/sdc-distribution-client/src/main/java/org/onap/sdc/impl/StatusConsumer.java
index 49ba428..5951ed0 100644
--- a/sdc-distribution-client/src/main/java/org/onap/sdc/impl/StatusConsumer.java
+++ b/sdc-distribution-client/src/main/java/org/onap/sdc/impl/StatusConsumer.java
@@ -7,9 +7,9 @@
  * Licensed 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.
@@ -31,36 +31,35 @@ import com.google.gson.GsonBuilder;
 
 class StatusConsumer implements Runnable {
 
-	private static Logger log = LoggerFactory.getLogger(StatusConsumer.class.getName());
+    private static Logger log = LoggerFactory.getLogger(StatusConsumer.class.getName());
 
-	private CambriaConsumer cambriaConsumer;
-	private IStatusCallback clientCallback;
+    private CambriaConsumer cambriaConsumer;
+    private IStatusCallback clientCallback;
 
-	public StatusConsumer(CambriaConsumer cambriaConsumer, IStatusCallback clientCallback) {
-		this.cambriaConsumer = cambriaConsumer;
-		this.clientCallback = clientCallback;
-	}
+    StatusConsumer(CambriaConsumer cambriaConsumer, IStatusCallback clientCallback) {
+        this.cambriaConsumer = cambriaConsumer;
+        this.clientCallback = clientCallback;
+    }
 
-	@Override
-	public void run() {
+    @Override
+    public void run() {
 
-		try {
-			Gson gson = new GsonBuilder().setPrettyPrinting().create();
-			for (String statusMsg : cambriaConsumer.fetch()) {
-				log.debug("received message from topic");
-				log.debug("recieved notification from broker: {}", statusMsg);
-				IStatusData statusData = gson.fromJson(statusMsg, StatusDataImpl.class);
-				clientCallback.activateCallback(statusData);
-				
-				
-			}
+        try {
+            Gson gson = new GsonBuilder().setPrettyPrinting().create();
+            for (String statusMsg : cambriaConsumer.fetch()) {
+                log.debug("received message from topic");
+                log.debug("recieved notification from broker: {}", statusMsg);
+                IStatusData statusData = gson.fromJson(statusMsg, StatusDataImpl.class);
+                clientCallback.activateCallback(statusData);
 
-		} catch (Exception e) {
-			log.error("Error exception occured when fetching with Cambria Client:{}", e.getMessage());
-			log.debug("Error exception occured when fetching with Cambria Client:{}", e.getMessage(), e);
-		}
-	}
 
+            }
+
+        } catch (Exception e) {
+            log.error("Error exception occured when fetching with Cambria Client:{}", e.getMessage());
+            log.debug("Error exception occured when fetching with Cambria Client:{}", e.getMessage(), e);
+        }
+    }
 
 
 }