1 files changed, 17 insertions, 18 deletions

diff --git a/src/main/java/com/att/nsa/mr/dme/client/SimpleExampleConsumer.java b/src/main/java/com/att/nsa/mr/dme/client/SimpleExampleConsumer.java
index bdd15d4..2886db5 100644
--- a/src/main/java/com/att/nsa/mr/dme/client/SimpleExampleConsumer.java
+++ b/src/main/java/com/att/nsa/mr/dme/client/SimpleExampleConsumer.java
@@ -38,14 +38,14 @@ public class SimpleExampleConsumer {
 
 	private static final Logger logger = LoggerFactory.getLogger(SimpleExampleConsumer.class);
 
-    private SimpleExampleConsumer() {
-    }
+	private SimpleExampleConsumer() {
+	}
 
 	public static void main(String[] args) {
 
 		long count = 0;
 		long nextReport = 5000;
-                String key;
+		String key;
 
 		final long startMs = System.currentTimeMillis();
 
@@ -54,24 +54,24 @@ public class SimpleExampleConsumer {
 			final MRConsumer cc = MRClientFactory.createConsumer("D:\\SG\\consumer.properties");
 			while (true) {
 				for (String msg : cc.fetch()) {
-                                        logger.debug("Message Received: " + msg);
+					logger.debug("Message Received: " + msg);
 				}
 				// Header for DME2 Call.
 				MultivaluedMap<String, Object> headersMap = MRClientFactory.HTTPHeadersMap;
-				for (MultivaluedMap.Entry<String,List<Object>> entry: headersMap.entrySet()) {
-                                    key = entry.getKey();
-                                    logger.debug("Header Key " + key);
-                                    logger.debug("Header Value " + headersMap.get(key));
+				for (MultivaluedMap.Entry<String, List<Object>> entry : headersMap.entrySet()) {
+					key = entry.getKey();
+					logger.debug("Header Key " + key);
+					logger.debug("Header Value " + headersMap.get(key));
 				}
 				// Header for HTTP Call.
-				
-				 Map<String, String> dme2headersMap=MRClientFactory.DME2HeadersMap;
-                                 for(Map.Entry<String,String> entry: dme2headersMap.entrySet()) {
-                                     key = entry.getKey();
-                                     logger.debug("Header Key " + key);
-                                     logger.debug("Header Value " + dme2headersMap.get(key));
-                                 }
-				 
+
+				Map<String, String> dme2headersMap = MRClientFactory.DME2HeadersMap;
+				for (Map.Entry<String, String> entry : dme2headersMap.entrySet()) {
+					key = entry.getKey();
+					logger.debug("Header Key " + key);
+					logger.debug("Header Value " + dme2headersMap.get(key));
+				}
+
 				if (count > nextReport) {
 					nextReport += 5000;
 
@@ -79,11 +79,10 @@ public class SimpleExampleConsumer {
 					final long elapsedMs = endMs - startMs;
 					final double elapsedSec = elapsedMs / 1000.0;
 					final double eps = count / elapsedSec;
-					logger.error("Consumed " + count + " in " + elapsedSec + "; " + eps + " eps");
 				}
 			}
 		} catch (Exception x) {
-                    logger.error(x.getClass().getName() + ": " + x.getMessage());
+			logger.error(x.getClass().getName() + ": " + x.getMessage());
 		}
 	}
 }