Replaced all tabs with spaces in java and pom.xml
[so.git] / common / src / main / java / org / onap / so / client / dmaap / DmaapPublisher.java
index 48691dc..158bc6e 100644 (file)
@@ -22,30 +22,30 @@ package org.onap.so.client.dmaap;
 
 import java.io.FileNotFoundException;
 import java.io.IOException;
-
 import org.onap.so.client.dmaap.rest.RestPublisher;
 
 public abstract class DmaapPublisher extends DmaapClient {
-       
-       private long seconds;
-       private final Publisher publisher;
-       public DmaapPublisher() throws FileNotFoundException, IOException {
-               super("dmaap/default-consumer.properties");
-               this.publisher = new RestPublisher(properties);
-               this.seconds = 20;
-               
-       }
-       
-       public DmaapPublisher(long seconds) throws FileNotFoundException, IOException {
-               this();
-               this.seconds = seconds;
-       }
-       
-       public void send(String json){
-               logger.info("publishing message to dmaap topic " + this.getTopic() + ": " + json);
-               publisher.send(json);
-               //publisher.close(seconds, TimeUnit.SECONDS);
-       }
+
+    private long seconds;
+    private final Publisher publisher;
+
+    public DmaapPublisher() throws FileNotFoundException, IOException {
+        super("dmaap/default-consumer.properties");
+        this.publisher = new RestPublisher(properties);
+        this.seconds = 20;
+
+    }
+
+    public DmaapPublisher(long seconds) throws FileNotFoundException, IOException {
+        this();
+        this.seconds = seconds;
+    }
+
+    public void send(String json) {
+        logger.info("publishing message to dmaap topic " + this.getTopic() + ": " + json);
+        publisher.send(json);
+        // publisher.close(seconds, TimeUnit.SECONDS);
+    }
 
 
 }