Merge "fixing code smells"
authorMandar Sawant <ms5838@att.com>
Thu, 9 Apr 2020 21:09:35 +0000 (21:09 +0000)
committerGerrit Code Review <gerrit@onap.org>
Thu, 9 Apr 2020 21:09:35 +0000 (21:09 +0000)
src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/Kafka011Consumer.java
src/main/java/org/onap/dmaap/dmf/mr/backends/kafka/KafkaConsumerCache.java
src/main/java/org/onap/dmaap/dmf/mr/beans/DMaaPKafkaMetaBroker.java
src/main/java/org/onap/dmaap/dmf/mr/resources/CambriaOutboundEventStream.java
src/main/java/org/onap/dmaap/dmf/mr/service/impl/ErrorResponseProvider.java

index 67a8af9..9449cd6 100644 (file)
@@ -23,7 +23,6 @@ package org.onap.dmaap.dmf.mr.backends.kafka;
 
 import java.net.InetAddress;
 import java.net.UnknownHostException;
-import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutorService;
index 647f4ce..56b3726 100644 (file)
@@ -22,7 +22,6 @@
 package org.onap.dmaap.dmf.mr.backends.kafka;
 
 import java.io.IOException;
-import java.net.InetAddress;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Enumeration;
@@ -34,8 +33,6 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
-import javax.annotation.Resource;
-
 import org.I0Itec.zkclient.exception.ZkException;
 import org.I0Itec.zkclient.exception.ZkInterruptedException;
 import org.apache.curator.framework.CuratorFramework;
@@ -52,8 +49,6 @@ import org.apache.http.annotation.NotThreadSafe;
 import org.apache.zookeeper.KeeperException;
 import org.apache.zookeeper.KeeperException.NoNodeException;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.context.annotation.ComponentScan;
 
 import com.att.ajsc.filemonitor.AJSCPropertiesMap;
 import org.onap.dmaap.dmf.mr.backends.Consumer;
index d7fa28b..b27a286 100644 (file)
@@ -53,7 +53,6 @@ import com.att.nsa.configs.ConfigDb;
 import com.att.nsa.configs.ConfigDbException;
 import com.att.nsa.configs.ConfigPath;
 import com.att.nsa.drumlin.service.standards.HttpStatusCodes;
-import com.att.nsa.drumlin.till.data.stringUtils;
 import com.att.nsa.drumlin.till.nv.rrNvReadable;
 import com.att.nsa.security.NsaAcl;
 import com.att.nsa.security.NsaAclUtils;
index 2f7f1db..dfe5e3b 100644 (file)
@@ -27,13 +27,8 @@ import java.util.ArrayList;
 import java.util.Date;
 
 import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-
-import org.apache.kafka.clients.consumer.ConsumerRecord;
-import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.json.JSONException;
 import org.json.JSONObject;
-import org.json.JSONTokener;
 
 import com.att.ajsc.filemonitor.AJSCPropertiesMap;
 import org.onap.dmaap.dmf.mr.CambriaApiException;
index 50a611e..da22345 100644 (file)
@@ -21,7 +21,6 @@ package org.onap.dmaap.dmf.mr.service.impl;
 import com.google.common.base.Preconditions;
 import java.util.Date;
 import org.apache.http.HttpStatus;
-import org.onap.dmaap.dmf.mr.beans.DMaaPContext;
 import org.onap.dmaap.dmf.mr.exception.DMaaPErrorMessages;
 import org.onap.dmaap.dmf.mr.exception.DMaaPResponseCode;
 import org.onap.dmaap.dmf.mr.exception.ErrorResponse;