summaryrefslogtreecommitdiffstats
path: root/src/main/java/com
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com')
-rw-r--r--src/main/java/com/att/dmf/mr/backends/kafka/Kafka011ConsumerUtil.java3
-rw-r--r--src/main/java/com/att/dmf/mr/backends/memory/MemoryQueue.java2
-rw-r--r--src/main/java/com/att/dmf/mr/metrics/publisher/impl/CambriaBaseClient.java2
-rw-r--r--src/main/java/com/att/dmf/mr/security/DMaaPAuthenticatorImpl.java2
-rw-r--r--src/main/java/com/att/dmf/mr/service/impl/BaseTransactionDbImpl.java2
-rw-r--r--src/main/java/com/att/dmf/mr/service/impl/UIServiceImpl.java2
6 files changed, 6 insertions, 7 deletions
diff --git a/src/main/java/com/att/dmf/mr/backends/kafka/Kafka011ConsumerUtil.java b/src/main/java/com/att/dmf/mr/backends/kafka/Kafka011ConsumerUtil.java
index ea9407b..271b155 100644
--- a/src/main/java/com/att/dmf/mr/backends/kafka/Kafka011ConsumerUtil.java
+++ b/src/main/java/com/att/dmf/mr/backends/kafka/Kafka011ConsumerUtil.java
@@ -25,8 +25,7 @@ import java.util.ArrayList;
import org.apache.kafka.clients.consumer.ConsumerRecords;
-//import org.slf4j.Logger;
-//import org.slf4j.LoggerFactory;
+
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
diff --git a/src/main/java/com/att/dmf/mr/backends/memory/MemoryQueue.java b/src/main/java/com/att/dmf/mr/backends/memory/MemoryQueue.java
index 8ab4619..25cb2df 100644
--- a/src/main/java/com/att/dmf/mr/backends/memory/MemoryQueue.java
+++ b/src/main/java/com/att/dmf/mr/backends/memory/MemoryQueue.java
@@ -44,7 +44,7 @@ public class MemoryQueue {
*/
public MemoryQueue() {
fQueue = new HashMap<>();
- fOffsets = new HashMap<String, HashMap<String, Integer>>();
+ fOffsets = new HashMap<>();
}
/**
diff --git a/src/main/java/com/att/dmf/mr/metrics/publisher/impl/CambriaBaseClient.java b/src/main/java/com/att/dmf/mr/metrics/publisher/impl/CambriaBaseClient.java
index 80904ea..84576fc 100644
--- a/src/main/java/com/att/dmf/mr/metrics/publisher/impl/CambriaBaseClient.java
+++ b/src/main/java/com/att/dmf/mr/metrics/publisher/impl/CambriaBaseClient.java
@@ -71,7 +71,7 @@ public class CambriaBaseClient extends HttpClient implements com.att.dmf.mr.metr
{
if ( a == null ) return null;
- final TreeSet<String> set = new TreeSet<String> ();
+ final TreeSet<String> set = new TreeSet<>();
for ( int i=0; i<a.length (); i++ )
{
set.add ( a.getString ( i ));
diff --git a/src/main/java/com/att/dmf/mr/security/DMaaPAuthenticatorImpl.java b/src/main/java/com/att/dmf/mr/security/DMaaPAuthenticatorImpl.java
index 4a83a1c..0ae0839 100644
--- a/src/main/java/com/att/dmf/mr/security/DMaaPAuthenticatorImpl.java
+++ b/src/main/java/com/att/dmf/mr/security/DMaaPAuthenticatorImpl.java
@@ -71,7 +71,7 @@ public class DMaaPAuthenticatorImpl<K extends NsaApiKey> implements DMaaPAuthent
* the size of the time window for request authentication
*/
public DMaaPAuthenticatorImpl(NsaApiDb<K> db, long authTimeWindowMs) {
- fAuthenticators = new LinkedList<DMaaPAuthenticator<K>>();
+ fAuthenticators = new LinkedList<>();
fAuthenticators.add(new DMaaPOriginalUebAuthenticator<K>(db, authTimeWindowMs));
}
diff --git a/src/main/java/com/att/dmf/mr/service/impl/BaseTransactionDbImpl.java b/src/main/java/com/att/dmf/mr/service/impl/BaseTransactionDbImpl.java
index a847f5f..104d7de 100644
--- a/src/main/java/com/att/dmf/mr/service/impl/BaseTransactionDbImpl.java
+++ b/src/main/java/com/att/dmf/mr/service/impl/BaseTransactionDbImpl.java
@@ -143,7 +143,7 @@ public class BaseTransactionDbImpl<K extends DMaaPTransactionObj> implements DMa
* @throws ConfigDbException
*/
public synchronized Set<String> loadAllTransactionObjs() throws ConfigDbException {
- final TreeSet<String> result = new TreeSet<String>();
+ final TreeSet<String> result = new TreeSet<>();
for (ConfigPath cp : fDb.loadChildrenNames(fBasePath)) {
result.add(cp.getName());
}
diff --git a/src/main/java/com/att/dmf/mr/service/impl/UIServiceImpl.java b/src/main/java/com/att/dmf/mr/service/impl/UIServiceImpl.java
index c8bb073..b624a39 100644
--- a/src/main/java/com/att/dmf/mr/service/impl/UIServiceImpl.java
+++ b/src/main/java/com/att/dmf/mr/service/impl/UIServiceImpl.java
@@ -76,7 +76,7 @@ public class UIServiceImpl implements UIService {
LOGGER.info("Fetching list of all api keys and returning in a templated form for display.");
Map<String, NsaSimpleApiKey> keyMap = getApiKeyDb(dmaapContext).loadAllKeyRecords();
- LinkedList<JSONObject> keyList = new LinkedList<JSONObject>();
+ LinkedList<JSONObject> keyList = new LinkedList<>();
JSONObject jsonList = new JSONObject();